- public async addElement(elementData: T): Promise<void> {
- await this.pool.execute(elementData);
- // Start worker sequentially to optimize memory at startup
- await Utils.sleep(Constants.START_WORKER_DELAY);
- }
-}
-
-class DynamicPool extends DynamicThreadPool<WorkerData> {
- private static instance: DynamicPool;
-
- private constructor(min: number, max: number, filename: string, opts?: DynamicThreadPoolOptions) {
- super(min, max, filename, opts);