X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Fdynamic.ts;h=b0a22346690bd36c471b6b45c844af8ffae098ea;hb=30d7f6e094a9b837fd85c74ef23188ab28e86644;hp=119e556dd2ccb454fec3ed9c89c20df5d76199c2;hpb=447eca603b96bc46303dfa16f3048b68ae576b0c;p=poolifier.git diff --git a/src/pools/thread/dynamic.ts b/src/pools/thread/dynamic.ts index 119e556d..b0a22346 100644 --- a/src/pools/thread/dynamic.ts +++ b/src/pools/thread/dynamic.ts @@ -1,6 +1,7 @@ -import { type PoolType, PoolTypes } from '../pool' +import { type Worker } from 'node:worker_threads' +import { type PoolOptions, type PoolType, PoolTypes } from '../pool' import { checkDynamicPoolSize } from '../utils' -import { FixedThreadPool, type ThreadPoolOptions } from './fixed' +import { FixedThreadPool } from './fixed' /** * A thread pool with a dynamic number of threads, but a guaranteed minimum number of threads. @@ -27,12 +28,15 @@ export class DynamicThreadPool< */ public constructor ( min: number, - protected readonly max: number, + max: number, filePath: string, - opts: ThreadPoolOptions = {} + opts: PoolOptions = {} ) { - super(min, filePath, opts) - checkDynamicPoolSize(this.numberOfWorkers, this.max) + super(min, filePath, opts, max) + checkDynamicPoolSize( + this.minimumNumberOfWorkers, + this.maximumNumberOfWorkers as number + ) } /** @inheritDoc */