Yoga.Om.WorkerBees

type WorkerPool input output = WorkerPool input output

Worker pool handle

type PoolConfig = { numWorkers :: Int, workerPath :: String }

Configuration for a worker pool

defaultPoolConfig :: String -> PoolConfig

Default pool configuration (4 workers)

makePool :: forall ctx errs input output. Sendable input => Sendable output => PoolConfig -> Om ctx errs (WorkerPool input output)

Create a worker pool. Must be paired with terminatePool.

makePoolWithData :: forall ctx errs input output a. Sendable input => Sendable output => Sendable a => PoolConfig -> a -> Om ctx errs (WorkerPool input output)

Create a worker pool with shared data accessible to all workers via workerData.

terminatePool :: forall ctx errs input output. WorkerPool input output -> Om ctx errs Unit

Terminate a worker pool and all its threads.

distributeWork :: forall ctx errs f input output. Traversable f => Sendable input => WorkerPool input output -> f input -> Om ctx errs (f output)

Distribute work across the worker pool in parallel. Each input is submitted to the pool and processed by the next available worker.

data Worker t0 t1 t2

class Sendable (a :: Type) 

Only Sendable things can be sent back and forth between a worker thread and its parent. These include things that are represented by JavaScript primitives. Arbitrary PureScript values cannot be sent, but variants, records and newtypes of these things can. If you have a newtype of some Sendable, you must wrap it.

Instances

• Sendable Int
• Sendable Number
• Sendable String
• Sendable Boolean
• (Sendable a) => Sendable (Array a)
• (Sendable a) => Sendable (Object a)
• (RowToList r rl, SendableRowList rl) => Sendable (Record r)
• (RowToList r rl, SendableRowList rl) => Sendable (Variant r)
• Sendable (SendWrapper a)
• Sendable Json
• Sendable Unit
• Sendable Void
• Sendable ArrayBuffer
• (Fail (Beside (Quote a) (Text " is not known to be Sendable"))) => Sendable a

newtype SharedInt

An atomic integer reference backed by SharedArrayBuffer. Can be shared across worker threads via toSendable/fromSendable.

newtype SharedMap a

A shared concurrent map backed by SharedArrayBuffer with striped locks. Keys are Strings, values must be JSON-serializable. The keyspace is split into N segments for N-way concurrency.

newtype SharedState a

Buffer layout:

• Int32 slot 0 (bytes 0..3): mutex lock (0 = unlocked, 1 = locked)
• Int32 slot 1 (bytes 4..7): data length in bytes
• Bytes 8..N: UTF-8 encoded JSON string A shared mutable state that can be accessed from multiple worker threads. Values are JSON-serialized into a SharedArrayBuffer with a spinlock mutex.