X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fabstract-worker.ts;h=03d954fe62f1933594e4f556511e9762b7093fb5;hb=0e19141a4c860c96cde0eac21023cef79e6b22f5;hp=0a6530e3889c61bb925ce4d787736ba72c104001;hpb=4dc274761ce688172117009d1b306077d321f461;p=poolifier.git diff --git a/src/worker/abstract-worker.ts b/src/worker/abstract-worker.ts index 0a6530e3..03d954fe 100644 --- a/src/worker/abstract-worker.ts +++ b/src/worker/abstract-worker.ts @@ -41,11 +41,6 @@ export abstract class AbstractWorker< */ protected readonly interval?: NodeJS.Timeout - /** - * This value is immediately set to true when the kill from the main worker is received. - */ - private isKilled: boolean = false - /** * Constructs a new poolifier worker. * @@ -95,7 +90,6 @@ export abstract class AbstractWorker< this.mainWorker = value.parent } else if (value.kill) { // Here is time to kill this worker, just clearing the interval - this.isKilled = true if (this.interval) clearInterval(this.interval) this.emitDestroy() } @@ -134,7 +128,7 @@ export abstract class AbstractWorker< * Check to see if the worker should be terminated, because its living too long. */ protected checkAlive (): void { - if (Date.now() - this.lastTask > this.maxInactiveTime && !this.isKilled) { + if (Date.now() - this.lastTask > this.maxInactiveTime) { this.sendToMainWorker({ kill: this.killBehavior }) } }