X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Fdynamic.ts;h=cd9d23253a040f44070da2fe0b0504da31aeb283;hb=refs%2Ftags%2Fv3.1.9;hp=1d3f3f5d3c64d0d94a367c17f92a6df1d2b4d75f;hpb=2431bdb4c2dc637169bf623a40fc6562f685e56e;p=poolifier.git diff --git a/src/pools/thread/dynamic.ts b/src/pools/thread/dynamic.ts index 1d3f3f5d..cd9d2325 100644 --- a/src/pools/thread/dynamic.ts +++ b/src/pools/thread/dynamic.ts @@ -1,4 +1,5 @@ import { type PoolType, PoolTypes } from '../pool' +import { checkDynamicPoolSize } from '../utils' import { FixedThreadPool, type ThreadPoolOptions } from './fixed' /** @@ -26,12 +27,15 @@ export class DynamicThreadPool< */ public constructor ( min: number, - protected readonly max: number, + max: number, filePath: string, opts: ThreadPoolOptions = {} ) { - super(min, filePath, opts) - this.checkDynamicPoolSize(this.numberOfWorkers, this.max) + super(min, filePath, opts, max) + checkDynamicPoolSize( + this.minimumNumberOfWorkers, + this.maximumNumberOfWorkers as number + ) } /** @inheritDoc */ @@ -39,11 +43,6 @@ export class DynamicThreadPool< return PoolTypes.dynamic } - /** @inheritDoc */ - protected get maxSize (): number { - return this.max - } - /** @inheritDoc */ protected get busy (): boolean { return this.full && this.internalBusy()