package moonpool

You can search for identifiers within the package.

in-package search v0.2.0

On This Page

Suspensions

moonpool
- Moonpool
  - Atomic
  - Blocking_queue
  - Chan
  - Fork_join
  - Fut
    
    INFIX
    
    Infix
    
    _
    
    Infix_local
  - Lock
  - Pool
    
    For_runner_implementors
  - Runner
    
    For_runner_implementors
  - Suspend_

Legend:
Library
Module
Module type
Parameter
Class
Class type

Moonpool

A pool within a bigger pool (ie the ocean). Here, we're talking about pools of Thread.t which live within a fixed pool of Domain.t.

module Pool : sig ... end

Thread pool.

module Runner : sig ... end

Abstract runner.

val start_thread_on_some_domain : ('a -> unit) -> 'a -> Thread.t

Similar to Thread.create, but it picks a background domain at random to run the thread. This ensures that we don't always pick the same domain to run all the various threads needed in an application (timers, event loops, etc.)

module Lock : sig ... end

Mutex-protected resource.

module Fut : sig ... end

Futures.

module Chan : sig ... end

Channels.

module Fork_join : sig ... end

Fork-join primitives.

module Blocking_queue : sig ... end

A simple blocking queue.

module Atomic : sig ... end

Atomic values.

Suspensions

module Suspend_ : sig ... end

Suspensions.