X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=9045b063675a7071d77097ae51d3aa4d7bb9cfcb;hb=2889bd70182e9e42c75d686ece3c288307e01d4f;hp=cc9408f2fed30acb97a0dfdca34d0994c245227e;hpb=af7f2788b6fcc39343d544551cf17c8f0dc5b757;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index cc9408f2..9045b063 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -130,10 +130,10 @@ export abstract class AbstractPool< /** * Constructs a new poolifier pool. * - * @param minimumNumberOfWorkers - Minimum number of workers that this pool should manage. + * @param minimumNumberOfWorkers - Minimum number of workers that this pool manages. * @param filePath - Path to the worker file. * @param opts - Options for the pool. - * @param maximumNumberOfWorkers - Maximum number of workers that this pool should manage. + * @param maximumNumberOfWorkers - Maximum number of workers that this pool manages. */ public constructor ( protected readonly minimumNumberOfWorkers: number, @@ -984,8 +984,8 @@ export abstract class AbstractPool< private async sendKillMessageToWorker (workerNodeKey: number): Promise { await new Promise((resolve, reject) => { - if (workerNodeKey < 0 || workerNodeKey >= this.workerNodes.length) { - reject(new Error(`Invalid worker node key '${workerNodeKey}'`)) + if (this.workerNodes?.[workerNodeKey] == null) { + resolve() return } const killMessageListener = (message: MessageValue): void => {