-import { PoolType } from '../pool'
-import type { ClusterPoolOptions } from './fixed'
+import { type Worker } from 'node:cluster'
+import { type PoolOptions, type PoolType, PoolTypes } from '../pool'
+import { checkDynamicPoolSize } from '../utils'
import { FixedClusterPool } from './fixed'
/**
* 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 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 serializable data.
- * @typeParam Response - Type of execution response. This can only be serializable data.
+ * @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
*/
*/
public constructor (
min: number,
- public readonly max: number,
+ max: number,
filePath: string,
- opts: ClusterPoolOptions = {}
+ opts: PoolOptions<Worker> = {}
) {
- super(min, filePath, opts)
+ super(min, filePath, opts, max)
+ checkDynamicPoolSize(
+ this.minimumNumberOfWorkers,
+ this.maximumNumberOfWorkers as number
+ )
}
/** @inheritDoc */
- public get type (): PoolType {
- return PoolType.DYNAMIC
- }
-
- /** @inheritDoc */
- public get size (): number {
- return this.max
- }
-
- /** @inheritDoc */
- protected get full (): boolean {
- return this.workerNodes.length === this.max
+ protected get type (): PoolType {
+ return PoolTypes.dynamic
}
/** @inheritDoc */