}
},
"poolifier": {
- "version": "2.0.0-beta.5",
- "resolved": "https://registry.npmjs.org/poolifier/-/poolifier-2.0.0-beta.5.tgz",
- "integrity": "sha512-dGaWRZ6H3VAitl4KaBXH3AJ6RLQMk4T9ufo2KFYsabsUrY8Gd2clOY+rU8kxWNk+Eel6f8QEdjsDmasGfQXoOA=="
+ "version": "1.2.1",
+ "resolved": "https://registry.npmjs.org/poolifier/-/poolifier-1.2.1.tgz",
+ "integrity": "sha512-kUH3JlLLO7JdAnRdtbgaSME5WDxgDzAuUk9+hapVHfXeI0VjpeuLnxLL8cUF7lEgrUE4m59scr5TFx5ajbPqXQ=="
},
"postcss": {
"version": "8.1.10",
},
"dependencies": {
"mongodb": "^3.6.4",
- "poolifier": "^2.0.0-beta.5",
+ "poolifier": "^1.2.1",
"source-map-support": "^0.5.19",
"tslib": "^2.1.0",
"uuid": "^8.3.2",
// Conditionally export ThreadWorker instance for pool usage
export let threadWorker;
if (Utils.workerPoolInUse()) {
- threadWorker = new ThreadWorker(startChargingStation, { maxInactiveTime: Constants.WORKER_POOL_MAX_INACTIVE_TIME, async: false });
+ threadWorker = new ThreadWorker<StationWorkerData>(startChargingStation, { maxInactiveTime: Constants.WORKER_POOL_MAX_INACTIVE_TIME, async: false });
}
if (!isMainThread) {
-import { JSONValue } from 'poolifier';
import { Worker } from 'worker_threads';
export enum WorkerProcessType {
elementsPerWorker?: number;
}
-export type WorkerData = JSONValue;
+export interface WorkerData { }
export interface StationWorkerData extends WorkerData {
index: number;