-import { DynamicThreadPool, type PoolEmitter, type PoolInfo } from 'poolifier';
+import type { EventEmitterAsyncResource } from 'node:events';
+
+import { DynamicThreadPool, type PoolInfo } from 'poolifier';
import { WorkerAbstract } from './WorkerAbstract';
import type { WorkerData, WorkerOptions } from './WorkerTypes';
import { WorkerAbstract } from './WorkerAbstract';
import type { WorkerData, WorkerOptions } from './WorkerTypes';
export class WorkerDynamicPool extends WorkerAbstract<WorkerData> {
private readonly pool: DynamicThreadPool<WorkerData>;
export class WorkerDynamicPool extends WorkerAbstract<WorkerData> {
private readonly pool: DynamicThreadPool<WorkerData>;
await this.pool.execute(elementData);
// Start element sequentially to optimize memory at startup
this.workerOptions.elementStartDelay! > 0 &&
await this.pool.execute(elementData);
// Start element sequentially to optimize memory at startup
this.workerOptions.elementStartDelay! > 0 &&