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
    
    Background_thread
    
    For_runner_implementors
    
    Runner
    
    For_runner_implementors
    
    Trigger
    
    Immediate_runner
    
    Exn_bt
    
    Lock
    
    Fut
    
    Advanced
    
    Infix
    
    Infix_local
    
    Chan
    
    Task_local_storage
    
    Thread_local_storage
    
    Blocking_queue
    
    Bounded_queue
    
    Atomic
- Library moonpool.dpool
  - Moonpool_dpool
- Library moonpool.fib
  - Moonpool_fib
    
    Fiber
    
    Fls
    
    Handle
    
    Set
    
    Map
    
    Main
- Library moonpool.forkjoin
  - Moonpool_forkjoin
- Library moonpool.private
  - Moonpool_private
    
    Atomic_
    
    Domain_
    
    Tracing_
    
    Ws_deque_
- Library moonpool.sync
  - Moonpool_sync
    
    Mutex
    
    Condition
    
    Lock
    
    Event
    
    Infix
    
    Semaphore
    
    Lazy
    
    Latch
    
    Ivar
    
    Stream
- Sources
  - moonpool
    
    background_thread.ml
    
    bb_queue.ml
    
    bounded_queue.ml
    
    chan.ml
    
    exn_bt.ml
    
    fifo_pool.ml
    
    fut.ml
    
    hmap_ls_.ml
    
    lock.ml
    
    moonpool.ml
    
    moonpool__.ml
    
    runner.ml
    
    task_local_storage.ml
    
    trigger.ml
    
    types_.ml
    
    worker_loop_.ml
    
    ws_pool.ml
  - moonpool.dpool
    
    moonpool_dpool.ml
  - moonpool.fib
    
    fiber.ml
    
    fls.ml
    
    handle.ml
    
    main.ml
    
    moonpool_fib.ml
    
    moonpool_fib__.ml
  - moonpool.forkjoin
    
    moonpool_forkjoin.ml
  - moonpool.private
    
    atomic_.ml
    
    domain_.ml
    
    moonpool_private.ml
    
    tracing_.ml
    
    ws_deque_.ml
  - moonpool.sync
    
    event.ml
    
    lock.ml
    
    moonpool_sync.ml
    
    moonpool_sync__.ml

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

Module `Fifo_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:(fiber:fiber -> 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 Thread_local_storage.t

Key that should be used by each runner to store itself in TLS on every thread it controls, so that tasks running on these threads can access the runner. This is necessary for get_current_runner to work.

package moonpool

Module Fifo_pool.For_runner_implementorsSource

Module `Fifo_pool.For_runner_implementors`Source