Std.Concurrent.Pool

poolInt -> Int -> Result[Std.Concurrent.Pool.Pool, Std.Concurrent.ConcurrentError]
A pool of workers threads over a queue holding at most queue jobs.
fn
Pool
A fixed set of workers draining a bounded queue.
type
queued&Std.Concurrent.Pool.Pool -> Result[Int, Std.Concurrent.ConcurrentError]
How many jobs are waiting for a worker.
fn
shutdown&Std.Concurrent.Pool.Pool -> Result[(), Std.Concurrent.ConcurrentError]
Refuse further jobs, run every queued one, and join every worker. Answers
fn
size&Std.Concurrent.Pool.Pool -> Int
How many workers the pool runs.
fn
submit&Std.Concurrent.Pool.Pool -> fn() -> () -> Result[(), Std.Concurrent.ConcurrentError]
Queue a job, waiting while the queue is full. A crash in the job is
fn
submitFor&Std.Concurrent.Pool.Pool -> fn() -> T -> Result[Std.Concurrent.Future.Future[T], Std.Concurrent.ConcurrentError]
Queue a job and answer the future of its value; a crash settles the
fn