tasks.h

Go to the documentation of this file.

#pragma once

 
#include <stddef.h>
 
#include <atomic>
#include <functional>
#include <memory>
#include <thread>
#include <vector>
 
namespace symmetri {

class TaskQueue;

class TaskSystem {
 public:
  using Task = std::function<void()>;

  explicit TaskSystem(size_t n_threads = std::thread::hardware_concurrency());
  ~TaskSystem() noexcept;
  TaskSystem(TaskSystem const&) = delete;
  TaskSystem(TaskSystem&&) noexcept = delete;
  TaskSystem& operator=(TaskSystem const&) = delete;
  TaskSystem& operator=(TaskSystem&&) noexcept = delete;

  void push(Task&& p) const;
 
 private:
  void loop();
  std::vector<std::thread> pool_;
  std::atomic<bool> is_running_;
  std::unique_ptr<TaskQueue> queue_;
};
 
}  // namespace symmetri