Storage: use worker threads message passing to store performance records from
[e-mobility-charging-stations-simulator.git] / src / worker / WorkerAbstract.ts
1 import Constants from '../utils/Constants';
2 import { WorkerData } from '../types/Worker';
3
4 export default abstract class WorkerAbstract {
5 protected readonly workerScript: string;
6 protected readonly workerStartDelay: number;
7 protected readonly messageListener: (message: any) => void;
8 public abstract size: number;
9 public abstract maxElementsPerWorker: number | null;
10
11 /**
12 * `WorkerAbstract` constructor.
13 *
14 * @param workerScript
15 * @param workerStartDelay
16 * @param messageListenerCallback
17 */
18 constructor(workerScript: string, workerStartDelay: number = Constants.WORKER_START_DELAY,
19 messageListenerCallback: (message: any) => void = () => { /* This is intentional */ }) {
20 this.workerScript = workerScript;
21 this.workerStartDelay = workerStartDelay;
22 this.messageListener = messageListenerCallback;
23 }
24
25 public abstract start(): Promise<void>;
26 public abstract stop(): Promise<void>;
27 public abstract addElement(elementData: WorkerData): Promise<void>;
28 }