7bf477dd837c0ce3e30cb65ad308c32ca0774f48
[poolifier.git] / src / pools / thread / dynamic.ts
1 import type { PoolOptions } from '../pool'
2 import { PoolType } from '../pool'
3 import type { ThreadWorkerWithMessageChannel } from './fixed'
4 import { FixedThreadPool } from './fixed'
5
6 /**
7 * A thread pool with a dynamic number of threads, but a guaranteed minimum number of threads.
8 *
9 * This thread pool creates new threads when the others are busy, up to the maximum number of threads.
10 * 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`.
11 *
12 * @typeParam Data - Type of data sent to the worker. This can only be serializable data.
13 * @typeParam Response - Type of response of execution. This can only be serializable data.
14 * @author [Alessandro Pio Ardizio](https://github.com/pioardi)
15 * @since 0.0.1
16 */
17 export class DynamicThreadPool<
18 Data = unknown,
19 Response = unknown
20 > extends FixedThreadPool<Data, Response> {
21 /**
22 * Constructs a new poolifier dynamic thread pool.
23 *
24 * @param min - Minimum number of threads which are always active.
25 * @param max - Maximum number of threads that can be created by this pool.
26 * @param filePath - Path to an implementation of a `ThreadWorker` file, which can be relative or absolute.
27 * @param opts - Options for this dynamic thread pool.
28 */
29 public constructor (
30 min: number,
31 public readonly max: number,
32 filePath: string,
33 opts: PoolOptions<ThreadWorkerWithMessageChannel> = {}
34 ) {
35 super(min, filePath, opts)
36 }
37
38 /** @inheritDoc */
39 public get type (): PoolType {
40 return PoolType.DYNAMIC
41 }
42
43 /** @inheritDoc */
44 protected get full (): boolean {
45 return this.workerNodes.length === this.max
46 }
47
48 /** @inheritDoc */
49 protected get busy (): boolean {
50 return this.full && this.internalBusy()
51 }
52 }