Std.Concurrent

11 public declarations

• ConcurrentError

  Why a thread could not be started, or what it said when it failed.

  type
• forEachBounded&Array[T] -> Int -> fn(T) -> () -> Result[(), Std.Concurrent.ConcurrentError]

  Apply an action to values with bounded concurrency, without implicit retries.

  fn
• join&Std.Concurrent.Task -> Result[(), Std.Concurrent.ConcurrentError]

  Wait for a thread to finish, and report what it said if it failed.

  fn
• joinAll&Array[Std.Concurrent.Task] -> Result[(), Std.Concurrent.ConcurrentError]

  Wait for every thread, in the order they were started.

  fn
• mapBounded&Array[T] -> Int -> fn(T) -> U -> Result[Array[U], Std.Concurrent.ConcurrentError]

  Map values with bounded concurrency, preserving input order and typed failures.

  fn
• mapResultBounded&Array[T] -> Int -> fn(T) -> Result[U, E] -> Result[Result[Array[U], E], Std.Concurrent.ConcurrentError]

  Apply a fallible transform with bounded concurrency, returning the first error in input order.

  fn
• parallel&Array[fn() -> ()] -> Result[(), Std.Concurrent.ConcurrentError]

  Run every action at once and wait for all of them.

  fn
• parallelBounded&Array[fn() -> ()] -> Int -> Result[(), Std.Concurrent.ConcurrentError]

  Run a batch with bounded workers; each action is claimed at most once.

  fn
• sleepInt -> Result[(), Std.Concurrent.ConcurrentError]

  Wait, without holding the machine while waiting.

  fn
• startfn() -> () -> Result[Std.Concurrent.Task, Std.Concurrent.ConcurrentError]

  Start an action on a thread of its own.

  fn
• Task

  A thread the program started.

  type