X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=a8a06a39a764fdc105f886e34ad8aab1d2075119;hb=8d8599f0565ba2121394a3d22214d13dbfa0f2c3;hp=c5b2d84a7797bbc12ccb6dfe3c0bfc635ebc031f;hpb=72092cfcf8a31c06e4592b25e060e2d74d2ed99c;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index c5b2d84a..a8a06a39 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -1,19 +1,18 @@ // Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved. -import { Worker } from 'worker_threads'; +import { Worker } from 'node:worker_threads'; -import WorkerAbstract from './WorkerAbstract'; -import { WorkerUtils } from './WorkerUtils'; +import { WorkerAbstract } from './WorkerAbstract'; import { type MessageHandler, type WorkerData, WorkerMessageEvents, type WorkerOptions, type WorkerSetElement, -} from '../types/Worker'; -import Utils from '../utils/Utils'; +} from './WorkerTypes'; +import { WorkerUtils } from './WorkerUtils'; -export default class WorkerSet extends WorkerAbstract { +export class WorkerSet extends WorkerAbstract { private readonly workerSet: Set; /** @@ -58,7 +57,7 @@ export default class WorkerSet extends WorkerAbstract { this.getLastWorkerSetElement().numberOfWorkerElements++; // Start element sequentially to optimize memory at startup if (this.workerOptions.elementStartDelay > 0) { - await Utils.sleep(this.workerOptions.elementStartDelay); + await WorkerUtils.sleep(this.workerOptions.elementStartDelay); } } @@ -105,7 +104,7 @@ export default class WorkerSet extends WorkerAbstract { this.workerSet.add({ worker, numberOfWorkerElements: 0 }); // Start worker sequentially to optimize memory at startup this.workerOptions.workerStartDelay > 0 && - (await Utils.sleep(this.workerOptions.workerStartDelay)); + (await WorkerUtils.sleep(this.workerOptions.workerStartDelay)); } private getLastWorkerSetElement(): WorkerSetElement {