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