X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Fdynamic.ts;h=b75b3f800d8dc771176b7f11fa437b3fedab867e;hb=d33be4309c69e39da5e81479e40b1a5ec7078bd5;hp=67020577d2be51aaedce5fb37015a0e3edddca91;hpb=1f68cedebde2cf95b6345300ac52cf7ca3ecbdff;p=poolifier.git diff --git a/src/pools/cluster/dynamic.ts b/src/pools/cluster/dynamic.ts index 67020577..b75b3f80 100644 --- a/src/pools/cluster/dynamic.ts +++ b/src/pools/cluster/dynamic.ts @@ -1,6 +1,5 @@ -import { PoolType } from '../pool' -import type { ClusterPoolOptions } from './fixed' -import { FixedClusterPool } from './fixed' +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. @@ -27,7 +26,7 @@ export class DynamicClusterPool< */ public constructor ( min: number, - public readonly max: number, + protected readonly max: number, filePath: string, opts: ClusterPoolOptions = {} ) { @@ -35,20 +34,15 @@ export class DynamicClusterPool< } /** @inheritDoc */ - public get type (): PoolType { - return PoolType.DYNAMIC + protected get type (): PoolType { + return PoolTypes.dynamic } /** @inheritDoc */ - public get size (): number { + protected get maxSize (): number { return this.max } - /** @inheritDoc */ - protected get full (): boolean { - return this.workerNodes.length >= this.max - } - /** @inheritDoc */ protected get busy (): boolean { return this.full && this.internalBusy()