Thread.h File Reference

Standard C++ implementation of the DelegateMQ IThread interface. More...

#include "delegate/IThread.h"
#include "./predef/util/Timer.h"
#include "ThreadMsg.h"
#include <thread>
#include <queue>
#include <atomic>
#include <condition_variable>
#include <future>
#include <optional>

Go to the source code of this file.

Classes
struct	ThreadMsgComparator
class	Thread
	Cross-platform thread for any system supporting C++11 std::thread (e.g. Windows, Linux). More...

Detailed Description

Standard C++ implementation of the DelegateMQ IThread interface.

See also

https://github.com/endurodave/DelegateMQ David Lafreniere, 2025.

This class provides a cross-platform implementation of the IThread interface using standard C++11 primitives (std::thread, std::mutex, std::condition_variable). It creates a dedicated worker thread with an event loop capable of processing asynchronous delegates and system messages.

Key Features:

• Priority Queue: Uses std::priority_queue to ensure high-priority delegate messages (e.g., system signals) are processed before lower-priority ones.
• Back Pressure: Supports a configurable maxQueueSize. If the queue is full, DispatchDelegate() blocks the caller until space is available, preventing memory exhaustion.
• Watchdog Integration: Includes a built-in heartbeat mechanism. If the thread loop stalls (deadlock or infinite loop), the watchdog timer detects the failure.
• Synchronized Start: Uses std::promise and std::future to ensure the thread is fully initialized and running before CreateThread() returns.
• Debug Support: Sets the native thread name (on supported OSs like Windows) to aid debugging in IDEs.