repositories
/
e-mobility-charging-stations-simulator.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
refactor(simulator): rename checkTemplateFile() -> checkTemplate()
[e-mobility-charging-stations-simulator.git]
/
src
/
worker
/
WorkerSet.ts
diff --git
a/src/worker/WorkerSet.ts
b/src/worker/WorkerSet.ts
index a8a06a39a764fdc105f886e34ad8aab1d2075119..eaa19ac8f384ed5ce591362696e13bfdf765ab5a 100644
(file)
--- a/
src/worker/WorkerSet.ts
+++ b/
src/worker/WorkerSet.ts
@@
-3,6
+3,7
@@
import { Worker } from 'node:worker_threads';
import { WorkerAbstract } from './WorkerAbstract';
import { Worker } from 'node:worker_threads';
import { WorkerAbstract } from './WorkerAbstract';
+import { WorkerConstants } from './WorkerConstants';
import {
type MessageHandler,
type WorkerData,
import {
type MessageHandler,
type WorkerData,
@@
-51,7
+52,7
@@
export class WorkerSet extends WorkerAbstract<WorkerData> {
await this.startWorker();
}
this.getLastWorker().postMessage({
await this.startWorker();
}
this.getLastWorker().postMessage({
- id: WorkerMessageEvents.
START_WORKER_ELEMENT
,
+ id: WorkerMessageEvents.
startWorkerElement
,
data: elementData,
});
this.getLastWorkerSetElement().numberOfWorkerElements++;
data: elementData,
});
this.getLastWorkerSetElement().numberOfWorkerElements++;
@@
-89,12
+90,9
@@
export class WorkerSet extends WorkerAbstract<WorkerData> {
const worker = new Worker(this.workerScript);
worker.on(
'message',
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) => {
);
worker.on('error', WorkerUtils.defaultErrorHandler.bind(this) as (err: Error) => void);
worker.on('exit', (code) => {