threadgroup.h

Go to the documentation of this file.

#ifndef DYSCO_THREADGROUP_H
#define DYSCO_THREADGROUP_H
 
#include <stdexcept>
#include <thread>
#include <vector>
 
namespace dyscostman {
 
class threadgroup {
 public:
  threadgroup() {}
  ~threadgroup() { join_all(); }
 
  template <typename T>
  void create_thread(T threadFunc) {
    _threads.emplace_back(threadFunc);
  }
 
  void join_all() {
    for (std::thread &t : _threads) {
      t.join();
    }
    _threads.clear();
  }
 
  bool empty() const { return _threads.empty(); }
 
 private:
  std::vector<std::thread> _threads;
};
 
}  // namespace dyscostman
 
#endif