executor use new WorkerPool

mmmdawn · Nov 22, 2022 · b9026ef · b9026ef
1 parent 44d36de
commit b9026ef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/batch_work_executor.ts b/src/batch_work_executor.ts
@@ -15,7 +15,7 @@ export class BatchWorkExecutor<Args extends any[], Ret = any> {
     }
 
     async execute(workIterable: Iterable<any>, workerFile: string, ...args: Args): Promise<any[]> {
-        this.workerPool = new WorkerPool(workerFile, {
+        this.workerPool = WorkerPool.getInstance(workerFile, {
             maxWorkers: this.maxWorkers,
         })
         _logger.info(`WorkerPool created.`)