WorkerPool

import { WorkerPool } from "destack:worker";

Pool of homogeneous workers.

1export class WorkerPool<T, R> {2    workers: Worker<T, R>[];3    request(message: T): AsyncResult<R, WorkerError>;4    terminate(): Promise<void>;5}

Members

workers: Worker<T, R>[]: The workers in this pool.
request(message: T): AsyncResult<R, WorkerError>: Send one request to an available worker.
terminate(): Promise<void>: Request shutdown for every worker.