Std.Concurrent.Coordinate

acquire&Std.Concurrent.Coordinate.Semaphore -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Take a permit, waiting until one is free.
fn
add&Std.Concurrent.Coordinate.WaitGroup -> Int -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Add outstanding work. Answers Finished once the group has been idle.
fn
available&Std.Concurrent.Coordinate.Semaphore -> Result[Int, Std.Concurrent.Coordinate.CoordinateError]
How many permits are free right now.
fn
CoordinateError
Why a coordination step did not do what it was asked.
type
countDown&Std.Concurrent.Coordinate.Latch -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Count down once; the count-down reaching zero opens the latch. Counting
fn
done&Std.Concurrent.Coordinate.WaitGroup -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Mark one piece of outstanding work done. The last one makes the group
fn
explain&Std.Concurrent.Coordinate.CoordinateError -> Str
A sentence saying what went wrong.
fn
isOpen&Std.Concurrent.Coordinate.Latch -> Bool
Whether the latch has opened.
fn
latchInt -> Std.Concurrent.Coordinate.Latch
A latch opening after count count-downs; a count below one opens at once.
fn
Latch
A gate that opens once its count reaches zero, waking every waiter.
type
onceStd.Concurrent.Coordinate.Once[T]
A value not yet computed.
fn
Once
A value computed at most once, by whichever caller asks first.
type
peek&Std.Concurrent.Coordinate.Once[T] -> Option[T]
The value if it has been computed.
fn
release&Std.Concurrent.Coordinate.Semaphore -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Return a permit. Answers Overreleased when no permit is out.
fn
resolve&Std.Concurrent.Coordinate.Once[T] -> fn() -> T -> Result[T, Std.Concurrent.Coordinate.CoordinateError]
The value, computing it with init if no caller has yet. init runs on a
fn
semaphoreInt -> Std.Concurrent.Coordinate.Semaphore
A semaphore holding count permits; a count below one is taken as one.
fn
Semaphore
A count of permits. The free ones wait in permits; out counts those
type
waitGroupStd.Concurrent.Coordinate.WaitGroup
A wait group with nothing outstanding.
fn
WaitGroup
A count of outstanding work that can be waited on until it returns to
type
waitGroupIdle&Std.Concurrent.Coordinate.WaitGroup -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Wait until nothing is outstanding. A group waited on with nothing added
fn
waitLatch&Std.Concurrent.Coordinate.Latch -> Result[(), Std.Concurrent.Coordinate.CoordinateError]
Wait until the latch opens.
fn
waitLatchWithin&Std.Concurrent.Coordinate.Latch -> Int -> Result[Bool, Std.Concurrent.Coordinate.CoordinateError]
Wait at most millis for the latch; answers whether it opened.
fn
withPermit&Std.Concurrent.Coordinate.Semaphore -> fn() -> T -> Result[T, Std.Concurrent.Coordinate.CoordinateError]
Run an action holding a permit. The action runs on a thread of its own,
fn