package moonpool

  1. Overview
  2. Docs
Pools of threads supported by a pool of domains

Install 

dune-project
 Dependency

github.com Readme Changelog Edit opam file Versions (11)

Authors

  1. S
    Simon Cruanes

Maintainers

  1. S
    Simon Cruanes

Sources

moonpool-0.9.tbz
sha256=7194610ba86525f05f9cda15c6f28790ab15804e840bc71269f4590d81d8a390
sha512=625092e840589f2fd46ab88cf72714f4b415d8de0d50e46d4c202149ad7d4e38416a2c5f0100addc23781d6000d3951682b22a915af7f0f69d260d7cf4add9de

doc/moonpool.private/Moonpool_private/Ws_deque_/index.html

Module Moonpool_private.Ws_deque_Source

Work-stealing deque.

Adapted from "Dynamic circular work stealing deque", Chase & Lev.

However note that this one is not dynamic in the sense that there is no resizing. Instead we return false when push fails, which keeps the implementation fairly lightweight.

Sourcetype 'a t

Deque containing values of type 'a

Sourceval create : dummy:'a -> unit -> 'a t

Create a new deque.

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

Push value at the bottom of deque. returns true if it succeeds. This must be called only by the owner thread.

Sourceval pop : 'a t -> 'a option

Pop value from the bottom of deque. This must be called only by the owner thread.

Sourceexception Empty
Sourceval pop_exn : 'a t -> 'a
Sourceval steal : 'a t -> 'a option

Try to steal from the top of deque. This is thread-safe.

Sourceval size : _ t -> int