X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=d3540098d4ca192ed0e93b6a491358435572c743;hb=192566ec60b064afa6f1377fbf667152d93d5fe6;hp=69df163bb5775d7ee1c38fe2c8ebd4594ced165e;hpb=4735284627d276d3532cb3bd4b6d7fe392bb6b8b;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 69df163b..d3540098 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -68,8 +68,7 @@ export abstract class AbstractPool< public readonly emitter?: PoolEmitter /** - * The task execution response promise map. - * + * The task execution response promise map: * - `key`: The message id of each submitted task. * - `value`: An object that contains the worker, the execution response promise resolve and reject callbacks. * @@ -662,7 +661,7 @@ export abstract class AbstractPool< ...{ size: Math.pow(this.maxSize, 2), concurrency: 1, - tasksStealing: true, + taskStealing: true, tasksStealingOnBackPressure: true }, ...tasksQueueOptions @@ -1170,7 +1169,7 @@ export abstract class AbstractPool< // Send the statistics message to worker. this.sendStatisticsMessageToWorker(workerNodeKey) if (this.opts.enableTasksQueue === true) { - if (this.opts.tasksQueueOptions?.tasksStealing === true) { + if (this.opts.tasksQueueOptions?.taskStealing === true) { this.workerNodes[workerNodeKey].onEmptyQueue = this.taskStealingOnEmptyQueue.bind(this) }