package moonpool

You can search for identifiers within the package.

in-package search v0.2.0

moonpool
- Library moonpool
  - Moonpool
    
    Ws_pool
    
    For_runner_implementors
    
    Fifo_pool
    
    For_runner_implementors
    
    Runner
    
    For_runner_implementors
    
    Immediate_runner
    
    For_runner_implementors
    
    Pool
    
    Lock
    
    Fut
    
    Infix
    
    Infix_local
    
    Chan
    
    Fork_join
    
    Thread_local_storage
    
    Blocking_queue
    
    Bounded_queue
    
    Atomic
- Sources
  - moonpool
    
    atomic_.ml
    
    bb_queue.ml
    
    bounded_queue.ml
    
    chan.ml
    
    domain_.ml
    
    fifo_pool.ml
    
    fork_join.ml
    
    fut.ml
    
    immediate_runner.ml
    
    lock.ml
    
    moonpool.ml
    
    moonpool__.ml
    
    runner.ml
    
    suspend_.ml
    
    thread_local_storage_.ml
    
    util_pool_.ml
    
    ws_deque_.ml
    
    ws_pool.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Ws_pool.For_runner_implementors`Source

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

Source

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.

Sourceval k_cur_runner : t option ref Moonpool__.Thread_local_storage_.key

package moonpool

Module Ws_pool.For_runner_implementorsSource

Module `Ws_pool.For_runner_implementors`Source