#ifndef thr_pool_h
#define thr_pool_h
-#include <vector>
-#include <thread>
-
+#include "types.h"
#include "fifo.h"
typedef std::function<void()> job_t;
class ThrPool {
public:
- ThrPool(int sz, bool blocking=true);
+ ThrPool(size_t sz, bool blocking=true);
~ThrPool();
bool addJob(const job_t &j);
private:
- int nthreads_;
+ size_t nthreads_;
bool blockadd_;
fifo<job_t> jobq_;