Class WorkerPool

constructor

• new WorkerPool(
      size: number,
      create: (events: WorkerEvents) => PoolWorker,
  ): WorkerPool

  Parameters

  • size: number
  • create: (events: WorkerEvents) => PoolWorker

  Returns WorkerPool

Readonlysize

close

• close(): Promise<void>

  Terminates every worker; queued tasks fail.

  Returns Promise<void>

run

• run<T>(tasks: readonly PoolTask[], timeoutMs?: number): Promise<T[]>

  Runs the tasks of one call under one deadline; resolves, in the order given, when all have answered. The heaviest weight is dispatched first, so the longest task does not start last.

  Type Parameters

  • T

  Parameters

  • tasks: readonly PoolTask[]
  • OptionaltimeoutMs: number

  Returns Promise<T[]>