-import { type ThreadPoolOptions, availableParallelism } from 'poolifier';
+import { availableParallelism } from 'poolifier';
import type { WorkerOptions } from './WorkerTypes';
export const DEFAULT_ELEMENT_START_DELAY = 0;
export const DEFAULT_WORKER_START_DELAY = 500;
-export const POOL_MAX_INACTIVE_TIME = 60000;
export const DEFAULT_POOL_MIN_SIZE = Math.floor(availableParallelism() / 2);
export const DEFAULT_POOL_MAX_SIZE = Math.round(availableParallelism() * 1.5);
export const DEFAULT_ELEMENTS_PER_WORKER = 1;
poolMinSize: DEFAULT_POOL_MIN_SIZE,
poolMaxSize: DEFAULT_POOL_MAX_SIZE,
elementsPerWorker: DEFAULT_ELEMENTS_PER_WORKER,
- poolOptions: {},
+ poolOptions: {
+ enableEvents: true,
+ restartWorkerOnError: true,
+ },
});
-
-export const DEFAULT_POOL_OPTIONS: ThreadPoolOptions = {
- enableEvents: true,
- restartWorkerOnError: true,
-};