X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Fdynamic.ts;h=ce28e421544131e2f3b5efbf762e66b1c8b71103;hb=9d9fb7b64a28d150583fe1bcd895893f6736d9d4;hp=f6c70126f41599b482c6a653923dad3a66bed964;hpb=ccd3ada6c3dd16a882523f9721d16f38e6a73cac;p=poolifier.git diff --git a/src/pools/cluster/dynamic.ts b/src/pools/cluster/dynamic.ts index f6c70126..ce28e421 100644 --- a/src/pools/cluster/dynamic.ts +++ b/src/pools/cluster/dynamic.ts @@ -1,72 +1,55 @@ -import type { Worker } from 'cluster' -import type { JSONValue } from '../../utility-types' -import type { ClusterPoolOptions } from './fixed' -import { FixedClusterPool } from './fixed' +import { checkDynamicPoolSize } from '../utils' +import { type PoolType, PoolTypes } from '../pool' +import { type ClusterPoolOptions, FixedClusterPool } from './fixed' /** * A cluster pool with a dynamic number of workers, but a guaranteed minimum number of workers. * * This cluster pool creates new workers when the others are busy, up to the maximum number of workers. - * When the maximum number of workers is reached, an event is emitted. If you want to listen to this event, use the pool's `emitter`. - * - * @template Data Type of data sent to the worker. - * @template Response Type of response of execution. + * When the maximum number of workers is reached and workers are busy, an event is emitted. If you want to listen to this event, use the pool's `emitter`. * + * @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) * @since 2.0.0 */ export class DynamicClusterPool< - Data extends JSONValue = JSONValue, - Response extends JSONValue = JSONValue + Data = unknown, + Response = unknown > extends FixedClusterPool { /** * Constructs a new poolifier dynamic cluster pool. * - * @param min Minimum number of workers which are always active. - * @param max Maximum number of workers that can be created by this pool. - * @param filename Path to an implementation of a `ClusterWorker` file, which can be relative or absolute. - * @param opts Options for this fixed cluster pool. Default: `{ maxTasks: 1000 }` + * @param min - Minimum number of workers which are always active. + * @param max - Maximum number of workers that can be created by this pool. + * @param filePath - Path to an implementation of a `ClusterWorker` file, which can be relative or absolute. + * @param opts - Options for this dynamic cluster pool. */ public constructor ( min: number, - public readonly max: number, - filename: string, - opts: ClusterPoolOptions = { maxTasks: 1000 } + max: number, + filePath: string, + opts: ClusterPoolOptions = {} ) { - super(min, filename, opts) + super(min, filePath, opts, max) + checkDynamicPoolSize( + this.minimumNumberOfWorkers, + this.maximumNumberOfWorkers as number + ) } - /** - * Choose a worker for the next task. - * - * It will first check for and return an idle worker. - * If all workers are busy, then it will try to create a new one up to the `max` worker count. - * If the max worker count is reached, the emitter will emit a `FullPool` event and it will fall back to using a round robin algorithm to distribute the load. - * - * @returns Cluster worker. - */ - protected chooseWorker (): Worker { - for (const [worker, numberOfTasks] of this.tasks) { - if (numberOfTasks === 0) { - // A worker is free, use it - return worker - } - } + /** @inheritDoc */ + protected shallCreateDynamicWorker (): boolean { + return !this.full && this.internalBusy() + } - if (this.workers.length === this.max) { - this.emitter.emit('FullPool') - return super.chooseWorker() - } + /** @inheritDoc */ + protected get type (): PoolType { + return PoolTypes.dynamic + } - // All workers are busy, create a new worker - const worker = this.createAndSetupWorker() - this.registerWorkerMessageListener(worker, message => { - const tasksInProgress = this.tasks.get(worker) - if (message.kill && !tasksInProgress) { - this.sendToWorker(worker, { kill: 1 }) - void this.destroyWorker(worker) - } - }) - return worker + /** @inheritDoc */ + protected get busy (): boolean { + return this.full && this.internalBusy() } }