X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Fdynamic.ts;h=b03ca47e27ab272233338e8e4fb751bb8de0d0e4;hb=658b9aa08266ed9a8ae3c0fc947d237fa2674f09;hp=d6a6e1ba870f9d1938e42f0dc0f70bf844243448;hpb=c97c7edb14ea0699cd82bce5d0ffe50ae26af667;p=poolifier.git diff --git a/src/pools/thread/dynamic.ts b/src/pools/thread/dynamic.ts index d6a6e1ba..b03ca47e 100644 --- a/src/pools/thread/dynamic.ts +++ b/src/pools/thread/dynamic.ts @@ -1,68 +1,50 @@ -import type { MessageValue } from '../../utility-types' -import type { PoolOptions } from '../abstract-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 min/max number of threads, is possible to execute tasks in sync or async mode as you prefer. + * A thread pool with a dynamic number of threads, but a guaranteed minimum number of threads. * - * This thread pool will create new workers when the other ones are busy, until the max number of threads, - * when the max number of threads is reached, an event will be emitted, if you want to listen this event use the emitter method. + * This thread pool creates new threads when the others are busy, up to the maximum number of threads. + * When the maximum number of threads 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 structured-cloneable data. + * @typeParam Response - Type of execution response. This can only be structured-cloneable data. * @author [Alessandro Pio Ardizio](https://github.com/pioardi) * @since 0.0.1 */ export class DynamicThreadPool< - // eslint-disable-next-line @typescript-eslint/no-explicit-any - Data = any, - // eslint-disable-next-line @typescript-eslint/no-explicit-any - Response = any + Data = unknown, + Response = unknown > extends FixedThreadPool { /** - * @param min Min number of threads that will be always active - * @param max Max number of threads that will be active - * @param filename A file path with implementation of `ThreadWorker` class, relative path is fine. - * @param opts An object with possible options for example `errorHandler`, `onlineHandler`. Default: `{ maxTasks: 1000 }` + * Constructs a new poolifier dynamic thread pool. + * + * @param min - Minimum number of threads which are always active. + * @param max - Maximum number of threads that can be created by this pool. + * @param filePath - Path to an implementation of a `ThreadWorker` file, which can be relative or absolute. + * @param opts - Options for this dynamic thread pool. */ public constructor ( min: number, - public readonly max: number, - filename: string, - opts: PoolOptions = { maxTasks: 1000 } + protected readonly max: number, + filePath: string, + opts: ThreadPoolOptions = {} ) { - super(min, filename, opts) + super(min, filePath, opts) } - protected chooseWorker (): ThreadWorkerWithMessageChannel { - let worker: ThreadWorkerWithMessageChannel | undefined - for (const entry of this.tasks) { - if (entry[1] === 0) { - worker = entry[0] - break - } - } + /** @inheritDoc */ + protected get type (): PoolType { + return PoolTypes.dynamic + } + + /** @inheritDoc */ + protected get maxSize (): number { + return this.max + } - if (worker) { - // a worker is free, use it - return worker - } else { - if (this.workers.length === this.max) { - this.emitter.emit('FullPool') - return super.chooseWorker() - } - // all workers are busy create a new worker - const worker = this.internalNewWorker() - worker.port2?.on('message', (message: MessageValue) => { - if (message.kill) { - this.sendToWorker(worker, { kill: 1 }) - void this.destroyWorker(worker) - // clean workers from data structures - const workerIndex = this.workers.indexOf(worker) - this.workers.splice(workerIndex, 1) - this.tasks.delete(worker) - } - }) - return worker - } + /** @inheritDoc */ + protected get busy (): boolean { + return this.full && this.internalBusy() } }