TaskManager.hpp

Go to the documentation of this file.

#pragma once

#include "Camera.hpp"

class manual_reset_event
{
    mutex m_mutex;              
    condition_variable m_cv;    
    bool m_signaled;            

public:
    manual_reset_event(bool signaled = false);

    void signal();
    void reset();
    void wait();
};

class auto_reset_event
{
    mutex m_mutex;              
    condition_variable m_cv;    
    uint m_signal;              

public:
    auto_reset_event();
    
    void signal();
    void signalN(uint n);
    void wait(uint nTimes = 1);
};

class TaskManager
{
    concurrency::concurrent_queue<function<void()>>     m_taskqueue;            
    vector<BOOL>                                        m_threadKeepAlive;      
    auto_reset_event                                    m_threadHasTodo;        
    vector<thread>                                      m_threads;              

public:
    TaskManager(Application* app);
    ~TaskManager();
    
    template<typename T>
    void schedule(T fnc)
    {
        m_taskqueue.push(fnc);
        m_threadHasTodo.signal();
    }
    template<typename T, typename TEvent>
    void schedule(T fnc, TEvent* event = nullptr)
    {
        m_taskqueue.push([fnc, event]
                         ()
                        {
                            fnc();

                            if (event)
                                event->signal();
                        });

        m_threadHasTodo.signal();
    }

private:

    void worker(BOOL* keepAlive);
};