Ws_pool.For_runner_implementors
This module is specifically intended for users who implement their own runners. Regular users of Moonpool should not need to look at it.
val 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.
Suspend_
Fork_join
val k_cur_runner : t option ref Moonpool__.Thread_local_storage_.key