package moonpool

  1. Overview
  2. Docs

Module Immediate_runner.For_runner_implementorsSource

This module is specifically intended for users who implement their own runners. Regular users of Moonpool should not need to look at it.

Sourceval create : size:(unit -> int) -> num_tasks:(unit -> int) -> shutdown:(wait:bool -> unit -> unit) -> run_async:(task -> unit) -> unit -> t

Create a new runner.

NOTE: the runner should support DLA and Suspend_ on OCaml 5.x, so that Fork_join and other 5.x features work properly.

Sourceval k_cur_runner : t option ref Moonpool__.Thread_local_storage_.key