X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=bf61cd477b153af111d835a0371d193d92ceb786;hb=8b7aa4204c27efd1dc699f7baea65b5262bd26b3;hp=1fea176c4f3884c1ce4778f891d059d9f48bbbde;hpb=369179f64c3ff184193bde82102acb22e61ffb78;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index 1fea176c..bf61cd47 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -1,4 +1,5 @@ import cluster, { type Worker } from 'node:cluster' + import type { MessageValue } from '../../utility-types.js' import { AbstractPool } from '../abstract-pool.js' import { type PoolOptions, type PoolType, PoolTypes } from '../pool.js' @@ -11,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) @@ -23,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, @@ -54,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, }) }