TaskController.h

/*
 *  Copyright (C) 2021 Ilya Entin
 */

#pragma once

#include <barrier>
#include <queue>

#include <boost/core/noncopyable.hpp>

#include "ThreadPoolBase.h"

using TaskPtr = std::shared_ptr<class Task>;
using TaskControllerPtr = std::shared_ptr<class TaskController>;
using TaskControllerWeakPtr = std::weak_ptr<class TaskController>;

class TaskController : public std::enable_shared_from_this<TaskController>,
		       private boost::noncopyable {
  enum Phase { PREPROCESSTASK, PROCESSTASK };
  class Worker : public Runnable {
    bool start() override { return true; }
    void stop() override {}
    void run() noexcept override;
    TaskControllerWeakPtr _taskController;
  public:
    explicit Worker(TaskControllerWeakPtr taskController);
  };
  using CompletionFunction = void (*) () noexcept;
  bool start();
  void stop();
  void push(TaskPtr task);
  void setNextTask();
  static void onTaskCompletion() noexcept;
  void onCompletion();
  std::atomic<bool> _stopped = false;
  std::barrier<CompletionFunction> _barrier;
  ThreadPoolBase _threadPool;
  std::mutex _queueMutex;
  std::condition_variable _queueCondition;
  std::queue<TaskPtr> _queue;
  TaskPtr _task;
  static TaskControllerPtr _instance;
  static Phase _phase;
  static std::mutex _mutex;
 public:
  TaskController();
  ~TaskController() = default;
  void processTask(TaskPtr task);
  static bool create();
  static void destroy();
  static TaskControllerWeakPtr getWeakPtr();
};