thread_pool.h

 
#ifndef _aspose_system_threading_thread_pool_h_
#define _aspose_system_threading_thread_pool_h_
 
#include <queue>
#include <mutex>
#include <condition_variable>
#include <system/object.h>
#include <system/multicast_delegate.h>
#include <system/shared_ptr.h>
 
namespace System { namespace Threading {
 
using WaitCallback = System::MulticastDelegate<void(System::SharedPtr<System::Object>)>;
 
class ThreadPool;
 
class ASPOSECPP_SHARED_CLASS ThreadPoolImpl
{
public:
    ASPOSECPP_SHARED_API bool QueueUserWorkItem(WaitCallback callback, const System::SharedPtr<System::Object>& state);
 
    ASPOSECPP_SHARED_API void GetAvailableThreads(int &wt, int &cpt);
    ASPOSECPP_SHARED_API void GetMaxThreads(int &wt, int &cpt);
    ASPOSECPP_SHARED_API void GetMinThreads(int &wt, int &cpt);
    ASPOSECPP_SHARED_API bool SetMaxThreads(int wt, int cpt);
    ASPOSECPP_SHARED_API bool SetMinThreads(int wt, int cpt);
 
    ASPOSECPP_SHARED_API ThreadPoolImpl();
    ASPOSECPP_SHARED_API ~ThreadPoolImpl();
 
    static ASPOSECPP_SHARED_API bool& GetInitialized();
    ASPOSECPP_SHARED_API void JoinAll();
 
protected:
    std::uint32_t m_max_threads;
    std::uint32_t m_min_threads;
    std::mutex m_mutex;
    std::condition_variable m_cv;
    typedef std::pair<WaitCallback, System::SharedPtr<System::Object>> Job;
    std::queue<Job> m_queue;
 
    ASPOSECPP_SHARED_API void Worker();
    ASPOSECPP_SHARED_API void AddWorkers(uint32_t amount);
    ASPOSECPP_SHARED_API void DelWorkers(uint32_t amount);
};
 
 
class ThreadPool: public System::Object
{
    RTTI_INFO(System::Threading::ThreadPool, ::System::BaseTypesInfo<System::Object>);
public:
    static ASPOSECPP_SHARED_API ThreadPoolImpl& GetInstance();
 
    ThreadPool(const ThreadPool&) = delete;
    void operator = (const ThreadPool&) = delete;
    
    static ASPOSECPP_SHARED_API bool QueueUserWorkItem(WaitCallback callback);
    static ASPOSECPP_SHARED_API bool QueueUserWorkItem(WaitCallback callback, const System::SharedPtr<System::Object>& state);
 
    static ASPOSECPP_SHARED_API void GetAvailableThreads(int &wt, int &cpt);
    static ASPOSECPP_SHARED_API void GetMaxThreads(int &wt, int &cpt);
    static ASPOSECPP_SHARED_API void GetMinThreads(int &wt, int &cpt);
 
    static ASPOSECPP_SHARED_API bool SetMaxThreads(int wt, int cpt);
    static ASPOSECPP_SHARED_API bool SetMinThreads(int wt, int cpt);
 
    static ASPOSECPP_SHARED_API void JoinAllThreads();
};
 
}} // System::Threading
 
#endif