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 `Moonpool.Bounded_queue`Source

A blocking queue of finite size.

This queue, while still using locks underneath (like the regular blocking queue) should be enough for usage under reasonable contention.

The bounded size is helpful whenever some form of backpressure is desirable: if the queue is used to communicate between producer(s) and consumer(s), the consumer(s) can limit the rate at which producer(s) send new work down their way. Whenever the queue is full, means that producer(s) will have to wait before pushing new work.

since 0.4

Sourcetype 'a t

A bounded queue.

Sourceval create : max_size:int -> unit -> 'a t

Sourceval close : _ t -> unit

close q closes q. No new elements can be pushed into q, and after all the elements still in q currently are pop'd, pop will also raise Closed.

Sourceexception Closed

Sourceval push : 'a t -> 'a -> unit

push q x pushes x at the end of the queue. If q is full, this will block until there is room for x.

raises Closed
if q is closed.

Sourceval try_push : force_lock:bool -> 'a t -> 'a -> bool

try_push q x attempts to push x into q, but abandons if it cannot acquire q or if q is full.

parameter force_lock
if true, use Mutex.lock (which can block under contention); if false, use Mutex.try_lock, which might return false even if there's room in the queue.

raises Closed
if q is closed.

Sourceval pop : 'a t -> 'a

pop q pops the first element off q. It blocks if q is empty, until some element becomes available.

raises Closed
if q is empty and closed.

Sourceval try_pop : force_lock:bool -> 'a t -> 'a option

try_pop ~force_lock q tries to pop the first element, or returns None if no element is available or if it failed to acquire q.

parameter force_lock
if true, use Mutex.lock (which can block under contention); if false, use Mutex.try_lock, which might return None even in presence of an element if there's contention.

raises Closed
if q is empty and closed.

Sourceval size : _ t -> int

Number of elements currently in q

Sourceval max_size : _ t -> int

Maximum size of the queue. See create.

Sourceval transfer : 'a t -> 'a Queue.t -> unit

transfer bq q2 transfers all elements currently available in bq into local queue q2, and clears bq, atomically. It blocks if bq is empty.

See Bb_queue.transfer for more details.

raises Closed
if bq is empty and closed.

Sourcetype 'a gen = unit -> 'a option

Sourcetype 'a iter = ('a -> unit) -> unit

Sourceval to_iter : 'a t -> 'a iter

to_iter q returns an iterator over all items in the queue. This might not terminate if q is never closed.

Sourceval to_gen : 'a t -> 'a gen

to_gen q returns a generator from the queue.

Sourceval to_seq : 'a t -> 'a Seq.t

to_gen q returns a (transient) sequence from the queue.

package moonpool

Module Moonpool.Bounded_queueSource

Module `Moonpool.Bounded_queue`Source