loop.h

Go to the documentation of this file.

// uvco (c) 2024 Lewin Bormann. See LICENSE for specific terms.
 
#pragma once
 
#include <uv.h>
 
#include "uvco/exception.h"
#include "uvco/loop/scheduler.h"
 
#include <coroutine>
 
namespace uvco {


class Loop {
public:
  // Don't use this constructor. Use `runMain()` instead.
  Loop();
  Loop(const Loop &) = delete;
  Loop(Loop &&) = delete;
  Loop &operator=(const Loop &) = delete;
  Loop &operator=(Loop &&) = delete;
  ~Loop();

  [[nodiscard]] uv_loop_t *uvloop() const;
 
  // Enqueue a suspended coroutine_handle for later resumption.
  static void enqueue(std::coroutine_handle<> handle);
  // Remove a handle from the event loop. Note: if the same handle is posted
  // again later, it may still be resumed.
  static void cancel(std::coroutine_handle<> handle);
 
  static std::coroutine_handle<> getNext();
 
private:
  // The default loop is the only loop that can be created. It is set/unset by
  // the constructor/destructor.
  static Loop *defaultLoop;
  static Scheduler &currentScheduler();
 
  friend void runLoop(Loop &);
  void run();
  // Run a single turn of the loop.
  void runOne();
 
  // Loop and scheduler should be kept at the same
  // place in memory.
  mutable uv_loop_t loop_;
  Scheduler scheduler_;
  bool stopped_ = false;
};

 
} // namespace uvco