Greg
24 lines
488 B
C++
24 lines
488 B
C++
#pragma once
|
|
#include <mutex>
|
|
#include <vector>
|
|
#include <queue>
|
|
#include <functional>
|
|
#include <thread>
|
|
|
|
class ThreadPool
|
|
{
|
|
public:
|
|
static void Init(int poolSize);
|
|
static void Term();
|
|
static void QueueJob(const std::function<void()>& job);
|
|
|
|
private:
|
|
static void WorkingLoop();
|
|
|
|
static bool ShouldRun;
|
|
static std::mutex JobQueueMtx;
|
|
static std::condition_variable MtxCondition;
|
|
static std::vector<OrbisPthread> ThreadsPool;
|
|
static std::queue<std::function<void()>> JobQueue;
|
|
};
|