Skuld.FiberPool.Server (skuld_concurrency v0.47.0)

View Source

An always-on process hosting a FiberPool scheduler with bidirectional message passing.

Summary

Types

fiber_key()

Functions

cancel(server, fiber_key)
resume(server, fiber_key, value)
start_link(fibers)

Types

fiber_key()

@type fiber_key() :: atom()

Functions

cancel(server, fiber_key)

@spec cancel(pid(), fiber_key()) :: :ok

resume(server, fiber_key, value)

@spec resume(pid(), fiber_key(), term()) :: :ok

start_link(fibers)

@spec start_link(keyword(Skuld.Comp.Types.computation())) :: {:ok, pid()}