scheduler.h

Go to the documentation of this file.

// uvco (c) 2023 Lewin Bormann. See LICENSE for specific terms.
 
#pragma once
 
#include <boost/assert.hpp>
#include <uv.h>
 
#include <coroutine>
#include <deque>
 
namespace uvco {


static constexpr bool logSchedulerOperations = false;

class Scheduler {
public:
  Scheduler();
  Scheduler(const Scheduler &) = delete;
  Scheduler(Scheduler &&) = delete;
  Scheduler &operator=(const Scheduler &) = delete;
  Scheduler &operator=(Scheduler &&) = delete;
  ~Scheduler();

  void enqueue(std::coroutine_handle<> handle);
 
  void cancel(std::coroutine_handle<> handle);

  void runAll();

  std::coroutine_handle<> getNext();

  void close();
 
  [[nodiscard]] bool empty() const { return resumable_.empty(); }
 
private:
  std::coroutine_handle<> getNextInner();
 
  std::deque<std::coroutine_handle<>> resumable_;
};
 
} // namespace uvco