Method ThreadPool

libVeles/src/thread_pool.h:46–68

Constructor launches the requested number of workers.

 public:
  /// Constructor launches the requested number of workers.
  explicit ThreadPool(
      size_t threads_number = std::thread::hardware_concurrency())
      : stop_(false) {
    assert(threads_number && "There must be 1 or more threads");
    workers_.reserve(threads_number);
    for(; threads_number; --threads_number) {
      workers_.emplace_back([this] {
        while (true) {
          std::function<void()> task;
          {
            std::unique_lock<std::mutex> lock(mutex_);
            condition_.wait(lock, [this]{ return stop_ || !tasks_.empty(); });
            if (stop_ && tasks_.empty()) {
              return;
            }
            task = std::move(tasks_.front());
            tasks_.pop();
          }
          task();
        }
      });
    }
  }

  ThreadPool(const ThreadPool&) = delete;
  ThreadPool& operator=(const ThreadPool&) = delete;