X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Ftypes%2FWorker.ts;h=7a96335535b5dbb4f98d847edbf9e37b4c7a7f26;hb=e0a50bcd7ae5a1b4ce22e39935f96a8f7e1222b4;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..7a963355 100644 --- a/src/types/Worker.ts +++ b/src/types/Worker.ts @@ -1,17 +1,36 @@ +import { JsonType } from './JsonType'; +import { PoolOptions } from 'poolifier'; import { Worker } from 'worker_threads'; -// FIXME: make it more generic -export interface WorkerData { - index: number; - templateFile: string; +export enum WorkerProcessType { + WORKER_SET = 'workerSet', + DYNAMIC_POOL = 'dynamicPool', + STATIC_POOL = 'staticPool' } +export interface WorkerOptions { + startDelay?: number; + poolMaxSize?: number; + poolMinSize?: number; + elementsPerWorker?: number; + poolOptions?: PoolOptions; + messageHandler?: (message: unknown) => void | Promise; +} + +export type WorkerData = JsonType; + export interface WorkerSetElement { - worker: Worker, - numberOfWorkerElements: number + worker: Worker; + numberOfWorkerElements: number; +} + +export interface WorkerMessage { + id: WorkerMessageEvents; + data: T; } -export enum WorkerEvents { +export enum WorkerMessageEvents { START_WORKER_ELEMENT = 'startWorkerElement', + STOP_WORKER_ELEMENT = 'stopWorkerElement' }