*
* 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)
> extends FixedThreadPool<Data, Response> {
/**
* 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.
super(min, filePath, opts, max)
checkDynamicPoolSize(
this.minimumNumberOfWorkers,
- // eslint-disable-next-line @typescript-eslint/no-non-null-assertion
- this.maximumNumberOfWorkers!
+ this.maximumNumberOfWorkers
)
}
/** @inheritDoc */
protected shallCreateDynamicWorker (): boolean {
- return !this.full && this.internalBusy()
+ return (!this.full && this.internalBusy()) || this.empty
}
/** @inheritDoc */