stdlib/Thread.h

Go to the documentation of this file.

#ifndef _THREAD_STD_H
#define _THREAD_STD_H
 
// @see https://github.com/endurodave/StdWorkerThread
// David Lafreniere, Feb 2017.
 
#include "delegate/IThread.h"
#include <thread>
#include <queue>
#include <mutex>
#include <atomic>
#include <condition_variable>
#include <future>
 
class ThreadMsg;
 
class Thread : public dmq::IThread
{
public:
    Thread(const std::string& threadName);
 
    ~Thread();
 
    bool CreateThread();
 
    void ExitThread();
 
    std::thread::id GetThreadId();
 
    static std::thread::id GetCurrentThreadId();
 
    std::string GetThreadName() { return THREAD_NAME; }
 
    size_t GetQueueSize();
 
    virtual void DispatchDelegate(std::shared_ptr<dmq::DelegateMsg> msg);
 
private:
    Thread(const Thread&) = delete;
    Thread& operator=(const Thread&) = delete;
 
    void Process();
 
    void SetThreadName(std::thread::native_handle_type handle, const std::string& name);
 
    std::unique_ptr<std::thread> m_thread;
    std::queue<std::shared_ptr<ThreadMsg>> m_queue;
    std::mutex m_mutex;
    std::condition_variable m_cv;
    const std::string THREAD_NAME;
 
    // Promise and future to synchronize thread start
    std::promise<void> m_threadStartPromise;
    std::future<void> m_threadStartFuture;
 
    std::atomic<bool> m_exit;
};
 
#endif