package moonpool

You can search for identifiers within the package.

in-package search v0.2.0

Pools of threads supported by a pool of domains

Install

dune-project

Dependency

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

Authors

S

Simon Cruanes

Maintainers

S

Simon Cruanes

Sources

moonpool-0.6.tbz

sha256=3efd095c82a37bba8c7ab6a2532aee3c445ebe1ecaed84ef3ffb560bc65e7633

sha512=e4bcab82e6638299c2d0beb1dbf204f7b43379a5387418c6edff85b9bf90c13ad1bdd8eb44b69cd421268d1bc45bcf918bcf77e1c924348211ac27d6643aac78

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.

Sourceval steal : 'a t -> 'a option

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

Sourceval size : _ t -> int