win32/Thread.h

Go to the documentation of this file.

#ifndef _THREAD_WIN32_H
#define _THREAD_WIN32_H
 
 
#include "delegate/IThread.h"
#include "./predef/util/Timer.h"
#include "ThreadMsg.h"
#include <queue>
#include <atomic>
#include <optional>
#include <string>
 
#ifdef _WIN32
#ifndef NOMINMAX
#define NOMINMAX
#endif
#include <Windows.h>
#endif
 
// Comparator for priority queue
struct ThreadMsgComparator {
    bool operator()(const std::shared_ptr<ThreadMsg>& a, const std::shared_ptr<ThreadMsg>& b) const {
        return static_cast<int>(a->GetPriority()) < static_cast<int>(b->GetPriority());
    }
};
 
class Thread : public dmq::IThread
{
public:
    Thread(const std::string& threadName, size_t maxQueueSize = 0);
 
    virtual ~Thread();
 
    bool CreateThread(std::optional<dmq::Duration> watchdogTimeout = std::nullopt);
 
    void ExitThread();
 
    DWORD GetThreadId();
 
    static DWORD GetCurrentThreadId();
 
    std::string GetThreadName() { return THREAD_NAME; }
 
    size_t GetQueueSize();
 
    virtual void DispatchDelegate(std::shared_ptr<dmq::DelegateMsg> msg) override;
 
private:
    Thread(const Thread&) = delete;
    Thread& operator=(const Thread&) = delete;
 
    static DWORD WINAPI ThreadProc(LPVOID lpParam);
 
    void Process();
 
    void WatchdogCheck();
 
    void ThreadCheck();
 
    HANDLE m_hThread = NULL;
    DWORD m_threadId = 0;
 
    // Manual-reset event to synchronize thread startup
    HANDLE m_hStartEvent = NULL;
 
    CRITICAL_SECTION m_cs;
 
    // Condition variable to wake up consumers when a message is enqueued
    CONDITION_VARIABLE m_cvNotEmpty;
 
    // Condition variable to wake up blocked producers when space is available
    CONDITION_VARIABLE m_cvNotFull;
 
    std::priority_queue<std::shared_ptr<ThreadMsg>,
        std::vector<std::shared_ptr<ThreadMsg>>,
        ThreadMsgComparator> m_queue;
 
    const std::string THREAD_NAME;
 
    // Max queue size for back pressure (0 = unlimited)
    const size_t MAX_QUEUE_SIZE;
 
    std::atomic<bool> m_exit;
 
    // Watchdog related members
    std::atomic<dmq::TimePoint> m_lastAliveTime;
    std::unique_ptr<Timer> m_watchdogTimer;
    dmq::ScopedConnection m_watchdogTimerConn;
    std::unique_ptr<Timer> m_threadTimer;
    dmq::ScopedConnection m_threadTimerConn;
    std::atomic<dmq::Duration> m_watchdogTimeout;
};
 
#endif