*/
constructor (worker: Worker, workerType: WorkerType, poolMaxSize: number) {
if (worker == null) {
- throw new Error('Cannot construct a worker node without a worker')
+ throw new TypeError('Cannot construct a worker node without a worker')
}
if (workerType == null) {
- throw new Error('Cannot construct a worker node without a worker type')
+ throw new TypeError(
+ 'Cannot construct a worker node without a worker type'
+ )
}
if (poolMaxSize == null) {
- throw new Error(
+ throw new TypeError(
'Cannot construct a worker node without a pool maximum size'
)
}
- if (isNaN(poolMaxSize)) {
- throw new Error(
- 'Cannot construct a worker node with a NaN pool maximum size'
+ if (!Number.isSafeInteger(poolMaxSize)) {
+ throw new TypeError(
+ 'Cannot construct a worker node with a pool maximum size that is not an integer'
)
}
this.worker = worker
}
private initTaskFunctionWorkerUsage (name: string): WorkerUsage {
- const getTaskQueueSize = (): number => {
- let taskQueueSize = 0
+ const getTaskFunctionQueueSize = (): number => {
+ let taskFunctionQueueSize = 0
for (const task of this.tasksQueue) {
- if (task.name === name) {
- ++taskQueueSize
+ if (
+ (task.name === DEFAULT_TASK_NAME &&
+ name === (this.info.taskFunctions as string[])[1]) ||
+ (task.name !== DEFAULT_TASK_NAME && name === task.name)
+ ) {
+ ++taskFunctionQueueSize
}
}
- return taskQueueSize
+ return taskFunctionQueueSize
}
return {
tasks: {
executed: 0,
executing: 0,
get queued (): number {
- return getTaskQueueSize()
+ return getTaskFunctionQueueSize()
},
failed: 0
},