X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Ftypes%2FWorker.ts;h=12c2ea369552b2d5a8049adbce2bced511a996d5;hb=96a52d088b4927e7bc51ea9282f502c2a6b67707;hp=bc93d76ea5c0f85514bca82b338605eb7b0675f2;hpb=c045d9a97ebdf3747b82746b733b0c60a7db3f32;p=e-mobility-charging-stations-simulator.git diff --git a/src/types/Worker.ts b/src/types/Worker.ts index bc93d76e..12c2ea36 100644 --- a/src/types/Worker.ts +++ b/src/types/Worker.ts @@ -1,17 +1,37 @@ -import { Worker } from 'worker_threads'; +import type { Worker } from 'worker_threads'; -// FIXME: make it more generic -export interface WorkerData { - index: number; - templateFile: string; -} +import type { PoolOptions } from 'poolifier'; -export interface WorkerSetElement { - worker: Worker, - numberOfWorkerElements: number +export enum WorkerProcessType { + WORKER_SET = 'workerSet', + DYNAMIC_POOL = 'dynamicPool', + STATIC_POOL = 'staticPool', } -export enum WorkerEvents { +export type MessageHandler = (this: T, message: unknown) => void; + +export type WorkerOptions = { + workerStartDelay?: number; + elementStartDelay?: number; + poolMaxSize?: number; + poolMinSize?: number; + elementsPerWorker?: number; + poolOptions?: PoolOptions; + messageHandler?: MessageHandler; +}; + +export type WorkerData = Record; + +export type WorkerSetElement = { + worker: Worker; + numberOfWorkerElements: number; +}; + +export type WorkerMessage = { + id: WorkerMessageEvents; + data: T; +}; + +export enum WorkerMessageEvents { START_WORKER_ELEMENT = 'startWorkerElement', } -