X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fthread%2Fdynamic.ts;h=b6d41e9ef9f7ff92cecf89e068c6493bafe696e3;hb=70e79e39c8c80f90dc8875cc74f2d5c4c077cf15;hp=56b923c4d2cd0f4c3800aba0b24abd41f83b4799;hpb=08f3f44cef6256fdbab1a2a56842b291fd6dcd42;p=poolifier.git diff --git a/src/pools/thread/dynamic.ts b/src/pools/thread/dynamic.ts index 56b923c4..b6d41e9e 100644 --- a/src/pools/thread/dynamic.ts +++ b/src/pools/thread/dynamic.ts @@ -1,7 +1,5 @@ -import type { PoolOptions } from '../pool' -import { PoolType } from '../pool' -import type { ThreadWorkerWithMessageChannel } from './fixed' -import { FixedThreadPool } from './fixed' +import { type PoolType, PoolTypes } from '../pool' +import { FixedThreadPool, type ThreadPoolOptions } from './fixed' /** * A thread pool with a dynamic number of threads, but a guaranteed minimum number of threads. @@ -28,25 +26,20 @@ export class DynamicThreadPool< */ public constructor ( min: number, - public readonly max: number, + protected readonly max: number, filePath: string, - opts: PoolOptions = {} + opts: ThreadPoolOptions = {} ) { super(min, filePath, opts) } /** @inheritDoc */ - public get type (): PoolType { - return PoolType.DYNAMIC + protected get type (): PoolType { + return PoolTypes.dynamic } /** @inheritDoc */ - protected get full (): boolean { - return this.workerNodes.length === this.max - } - - /** @inheritDoc */ - public get size (): number { + protected get maxSize (): number { return this.max }