X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=0685f998d4aaf11d0cb93d86fcdb24b0e3476fbc;hb=3ec964d666b2ffa57b57a37a29542a727fc55ee6;hp=879e3e4f78f2b3ab60a5918a865fa7c711e3d882;hpb=ccd3ada6c3dd16a882523f9721d16f38e6a73cac;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 879e3e4f..0685f998 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -190,23 +190,23 @@ export abstract class AbstractPool< * @param worker Workers whose tasks are increased. */ protected increaseWorkersTask (worker: Worker): void { - const numberOfTasksTheWorkerHas = this.tasks.get(worker) - if (numberOfTasksTheWorkerHas !== undefined) { - this.tasks.set(worker, numberOfTasksTheWorkerHas + 1) + const numberOfTasksInProgress = this.tasks.get(worker) + if (numberOfTasksInProgress !== undefined) { + this.tasks.set(worker, numberOfTasksInProgress + 1) } else { throw Error('Worker could not be found in tasks map') } } /** - * Increase the number of tasks that the given workers has done. + * Decrease the number of tasks that the given workers has done. * - * @param worker Workers whose tasks are increased. + * @param worker Workers whose tasks are decreased. */ protected decreaseWorkersTasks (worker: Worker): void { - const numberOfTasksTheWorkerHas = this.tasks.get(worker) - if (numberOfTasksTheWorkerHas !== undefined) { - this.tasks.set(worker, numberOfTasksTheWorkerHas - 1) + const numberOfTasksInProgress = this.tasks.get(worker) + if (numberOfTasksInProgress !== undefined) { + this.tasks.set(worker, numberOfTasksInProgress - 1) } else { throw Error('Worker could not be found in tasks map') }