scheduler.h

Go to the documentation of this file.

// uvco (c) 2023 Lewin Bormann. See LICENSE for specific terms.
 
#pragma once
 
#include <array>
#include <boost/assert.hpp>
#include <uv.h>
 
#include <coroutine>
#include <vector>
 
namespace uvco {
 
 
class Scheduler {
public:
  enum class RunMode {
    Immediate = 0,
    Deferred = 1,
  };
 
  explicit Scheduler(RunMode mode = RunMode::Deferred);
 
  Scheduler(const Scheduler &) = delete;
  Scheduler(Scheduler &&) = delete;
  Scheduler &operator=(const Scheduler &) = delete;
  Scheduler &operator=(Scheduler &&) = delete;
  ~Scheduler();
 
  void setUpLoop(uv_loop_t *loop);
 
  void enqueue(std::coroutine_handle<> handle);
 
  void runAll();
 
  void close();
 
  [[nodiscard]] bool empty() const { return resumableActive_.empty(); }
 
private:
  // Vector of coroutine handles to be resumed.
  std::vector<std::coroutine_handle<>> resumableActive_;
  // Vector of coroutines currently being resumed (while in runAll()).
  std::vector<std::coroutine_handle<>> resumableRunning_;
 
  RunMode run_mode_;
};
 
} // namespace uvco