X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerStaticPool.ts;h=cf46cfa55f7662f671a5a24635c1f9566feb55f4;hb=e71712800639b0aaebec9af189fdbbaa4f453b92;hp=7a304b707d62b0083c98ce82795921f5ff92072c;hpb=101196c654ddcd686e4992f58864f591ceea6c00;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerStaticPool.ts b/src/worker/WorkerStaticPool.ts index 7a304b70..cf46cfa5 100644 --- a/src/worker/WorkerStaticPool.ts +++ b/src/worker/WorkerStaticPool.ts @@ -4,6 +4,7 @@ import Utils from '../utils/Utils'; import { Worker } from 'worker_threads'; import WorkerAbstract from './WorkerAbstract'; import { WorkerData } from '../types/Worker'; +import { WorkerUtils } from './WorkerUtils'; export default class WorkerStaticPool extends WorkerAbstract { private pool: StaticPool; @@ -68,11 +69,7 @@ class StaticPool extends FixedThreadPool { public static getInstance(numberOfThreads: number, workerScript: string, opts?: PoolOptions): StaticPool { if (!StaticPool.instance) { - opts.exitHandler = opts?.exitHandler ?? ((code) => { - if (code !== 0) { - console.error(`Worker stopped with exit code ${code}`); - } - }); + opts.exitHandler = opts?.exitHandler ?? WorkerUtils.defaultExitHandler; StaticPool.instance = new StaticPool(numberOfThreads, workerScript, opts); } return StaticPool.instance;