X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=bf61cd477b153af111d835a0371d193d92ceb786;hb=8b7aa4204c27efd1dc699f7baea65b5262bd26b3;hp=4a8cb4f1eeeafeb59adf1e30c5d678328cb19b70;hpb=ea4b5fd037c5fe09eb6a2810332ad6bed1b5bc7f;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index 4a8cb4f1..bf61cd47 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -12,7 +12,6 @@ export type ClusterPoolOptions = PoolOptions /** * A cluster pool with a fixed number of workers. - * * @typeParam Data - Type of data sent to the worker. This can only be structured-cloneable data. * @typeParam Response - Type of execution response. This can only be structured-cloneable data. * @author [Christopher Quadflieg](https://github.com/Shinigami92) @@ -24,10 +23,10 @@ export class FixedClusterPool< > extends AbstractPool { /** * Constructs a new poolifier fixed cluster pool. - * * @param numberOfWorkers - Number of workers for this pool. * @param filePath - Path to an implementation of a `ClusterWorker` file, which can be relative or absolute. * @param opts - Options for this fixed cluster pool. + * @param maximumNumberOfWorkers - The maximum number of workers for this pool. */ public constructor ( numberOfWorkers: number, @@ -55,14 +54,14 @@ export class FixedClusterPool< ): void { this.workerNodes[workerNodeKey]?.worker.send({ ...message, - workerId: this.getWorkerInfo(workerNodeKey)?.id + workerId: this.getWorkerInfo(workerNodeKey)?.id, } satisfies MessageValue) } /** @inheritDoc */ protected sendStartupMessageToWorker (workerNodeKey: number): void { this.sendToWorker(workerNodeKey, { - ready: false + ready: false, }) }