import { Worker } from 'node:worker_threads';
import { WorkerAbstract } from './WorkerAbstract';
+import { WorkerConstants } from './WorkerConstants';
import {
type MessageHandler,
type WorkerData,
await this.startWorker();
}
this.getLastWorker().postMessage({
- id: WorkerMessageEvents.START_WORKER_ELEMENT,
+ id: WorkerMessageEvents.startWorkerElement,
data: elementData,
});
this.getLastWorkerSetElement().numberOfWorkerElements++;
const worker = new Worker(this.workerScript);
worker.on(
'message',
- (
- this.workerOptions?.messageHandler ??
- (() => {
- /* This is intentional */
- })
- ).bind(this) as MessageHandler<Worker>
+ (this.workerOptions?.messageHandler ?? WorkerConstants.EMPTY_FUNCTION).bind(
+ this
+ ) as MessageHandler<Worker>
);
worker.on('error', WorkerUtils.defaultErrorHandler.bind(this) as (err: Error) => void);
worker.on('exit', (code) => {