typedef function<void()> job_t;
class ThrPool {
- public:
- ThrPool(size_t sz, bool blocking=true);
- ~ThrPool();
+ public:
+ ThrPool(size_t sz, bool blocking=true);
+ ~ThrPool();
- bool addJob(const job_t &j);
+ bool addJob(const job_t &j);
- private:
+ private:
size_t nthreads_;
- bool blockadd_;
+ bool blockadd_;
- fifo<job_t> jobq_;
- vector<thread> th_;
+ fifo<job_t> jobq_;
+ vector<thread> th_;
void do_worker();
};