return isMaster
}
- protected destroyWorker (worker: Worker): void {
+ /** @inheritdoc */
+ public destroyWorker (worker: Worker): void {
this.sendToWorker(worker, { kill: 1 })
worker.kill()
}
worker.send(message)
}
- protected registerWorkerMessageListener<Message extends Data | Response> (
+ /** @inheritdoc */
+ public registerWorkerMessageListener<Message extends Data | Response> (
worker: Worker,
listener: (message: MessageValue<Message>) => void
): void {
}
protected afterWorkerSetup (worker: Worker): void {
- // we will attach a listener for every task,
+ // We will attach a listener for every task,
// when task is completed the listener will be removed but to avoid warnings we are increasing the max listeners size
worker.setMaxListeners(this.opts.maxTasks ?? 1000)
}