Class ThreadPoolManager

src/ThreadPool.h:33–71

class ThreadArg;

class ThreadPoolManager {

public:
  enum Flags {
	VERBOSE = 1
  };

  static void init(unsigned int max_threads, unsigned int flags = 0) {
	assert(instance == NULL);
	instance = new ThreadPoolManager(max_threads, flags);
  }

  static ThreadPoolManager* getInstance() {
	return instance;
  }

  bool reserveOneThread();
  void releaseOneThread();
  unsigned int getMaxThreads() const {return max_threads;}
  unsigned int getFlags() const {return flags;}

  bool isMainThread() const {return pthread_self() == main_pthread;}

  ThreadPool* newThreadPool(const std::string& name);

  void lock() const;
  void unlock() const;

private:
  static ThreadPoolManager* instance;

  unsigned int max_threads;
  unsigned int flags;
  unsigned int available_threads;
  mutable pthread_mutex_t mp;
  pthread_t main_pthread;

  ThreadPoolManager(unsigned int max_threads, unsigned int flags = 0);
};

class Thread {
  static const int WAIT_USECONDS = 50000;