on(event: 'error', handler: ErrorHandler<this>): void
on(event: 'online', handler: OnlineHandler<this>): void
on(event: 'exit', handler: ExitHandler<this>): void
+ once(event: 'exit', handler: ExitHandler<this>): void
}
/**
}
public async destroy (): Promise<void> {
- for (const worker of this.workers) {
- await this.destroyWorker(worker)
- }
+ await Promise.all(this.workers.map(worker => this.destroyWorker(worker)))
}
/**
*/
protected chooseWorker (): Worker {
const chosenWorker = this.workers[this.nextWorkerIndex]
- this.nextWorkerIndex++
- this.nextWorkerIndex %= this.workers.length
+ this.nextWorkerIndex =
+ this.workers.length - 1 === this.nextWorkerIndex
+ ? 0
+ : this.nextWorkerIndex + 1
return chosenWorker
}
message: MessageValue<Data>
): void
- protected abstract registerWorkerMessageListener (
- port: Worker,
- listener: (message: MessageValue<Response>) => void
- ): void
+ protected abstract registerWorkerMessageListener<
+ Message extends Data | Response
+ > (worker: Worker, listener: (message: MessageValue<Message>) => void): void
- protected abstract unregisterWorkerMessageListener (
- port: Worker,
- listener: (message: MessageValue<Response>) => void
- ): void
+ protected abstract unregisterWorkerMessageListener<
+ Message extends Data | Response
+ > (worker: Worker, listener: (message: MessageValue<Message>) => void): void
protected internalExecute (
worker: Worker,
worker.on('error', this.opts.errorHandler ?? (() => {}))
worker.on('online', this.opts.onlineHandler ?? (() => {}))
- // TODO handle properly when a worker exit
worker.on('exit', this.opts.exitHandler ?? (() => {}))
+ worker.once('exit', () => this.removeWorker(worker))
this.workers.push(worker)