threadx/Thread.h

Go to the documentation of this file.

#ifndef _THREAD_THREADX_H
#define _THREAD_THREADX_H
 
 
#include "delegate/IThread.h"
#include "tx_api.h"
#include <string>
#include <memory>
#include <vector>
 
class ThreadMsg;
 
class Thread : public dmq::IThread
{
public:
    static const ULONG DEFAULT_QUEUE_SIZE = 20;
 
    Thread(const std::string& threadName, size_t maxQueueSize = 0);
 
    ~Thread();
 
    bool CreateThread();
 
    void ExitThread();
 
    TX_THREAD* GetThreadId();
 
    static TX_THREAD* GetCurrentThreadId();
 
    void SetThreadPriority(UINT priority);
 
    UINT GetThreadPriority();
 
    std::string GetThreadName() { return THREAD_NAME; }
 
    // IThread Interface Implementation
    virtual void DispatchDelegate(std::shared_ptr<dmq::DelegateMsg> msg) override;
 
private:
    Thread(const Thread&) = delete;
    Thread& operator=(const Thread&) = delete;
 
    static void Process(ULONG instance);
 
    // Run loop called by Process
    void Run();
 
    // ThreadX Control Blocks
    TX_THREAD m_thread;
    TX_QUEUE m_queue;
    TX_SEMAPHORE m_exitSem; // Semaphore to signal thread completion
 
    // Memory buffers required by ThreadX (Managed by RAII)
    // Using ULONG[] ensures correct alignment for ThreadX stacks and queues
    std::unique_ptr<ULONG[]> m_stackMemory;
    std::unique_ptr<ULONG[]> m_queueMemory;
    
    const std::string THREAD_NAME;
    
    // Configurable stack size (bytes)
    static const ULONG STACK_SIZE = 2048; 
    
    size_t m_queueSize; // Stored queue size
    UINT m_priority;    // Stored priority
};
 
#endif // _THREAD_THREADX_H