freertos/Thread.h

Go to the documentation of this file.

#ifndef _THREAD_FREERTOS_H
#define _THREAD_FREERTOS_H
 
 
#include "delegate/IThread.h"
#include "FreeRTOS.h"
#include "task.h"
#include "queue.h"
#include "semphr.h"
#include <string>
#include <memory>
 
class ThreadMsg;
 
class Thread : public dmq::IThread
{
public:
    static const size_t DEFAULT_QUEUE_SIZE = 20;
 
    Thread(const std::string& threadName, size_t maxQueueSize = 0);
 
    ~Thread();
 
    bool CreateThread();
 
    void ExitThread();
 
    TaskHandle_t GetThreadId();
 
    static TaskHandle_t GetCurrentThreadId();
 
    std::string GetThreadName() { return THREAD_NAME; }
 
    void SetThreadPriority(int priority);
 
    void SetStackMem(StackType_t* stackBuffer, uint32_t stackSizeInWords);
 
    // 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(void* instance);
 
    // Run loop called by Process
    void Run();
 
    TaskHandle_t m_thread = nullptr;
    QueueHandle_t m_queue = nullptr;
    SemaphoreHandle_t m_exitSem = nullptr; // Synchronization for safe destruction
 
    const std::string THREAD_NAME;
    size_t m_queueSize;
    int m_priority;
 
    // Static allocation support
    StackType_t* m_stackBuffer = nullptr;
    uint32_t m_stackSize = 1024; // Default size (words)
    StaticTask_t m_tcb;          // TCB storage for static creation
};
 
#endif