Results for “Std.Concurrent.Pool.Pool”

Use module:Std.List, kind:fn, or is:exact. Put a Pudu type after ::.

• Std.Concurrent.Pool.Pool

  A fixed set of workers draining a bounded queue.

  type · Std.Concurrent.Pool
• 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 · Std.Concurrent.Pool
• Std.Concurrent.Pool.queued&Std.Concurrent.Pool.Pool -> Result[Int, Std.Concurrent.ConcurrentError]

  How many jobs are waiting for a worker.

  fn · Std.Concurrent.Pool
• Std.Concurrent.Pool.shutdown&Std.Concurrent.Pool.Pool -> Result[(), Std.Concurrent.ConcurrentError]

  Refuse further jobs, run every queued one, and join every worker. Answers

  fn · Std.Concurrent.Pool
• Std.Concurrent.Pool.size&Std.Concurrent.Pool.Pool -> Int

  How many workers the pool runs.

  fn · Std.Concurrent.Pool
• Std.Concurrent.Pool.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 · Std.Concurrent.Pool
• Std.Concurrent.Pool.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 · Std.Concurrent.Pool