- /** {@inheritDoc} */
- public choose (): number {
- const chosenWorkerKey = this.currentWorkerId
- if (this.isDynamicPool && !this.workersTaskRunTime.has(chosenWorkerKey)) {
- this.initWorkerTaskRunTime(chosenWorkerKey)
- }
- const workerTaskRunTime =
- this.workersTaskRunTime.get(chosenWorkerKey)?.runTime ?? 0
- const workerTaskWeight =
- this.workersTaskRunTime.get(chosenWorkerKey)?.weight ??
- this.defaultWorkerWeight
- if (workerTaskRunTime < workerTaskWeight) {
- this.setWorkerTaskRunTime(
- chosenWorkerKey,
- workerTaskWeight,
- workerTaskRunTime +
- (this.getWorkerVirtualTaskRunTime(chosenWorkerKey) ?? 0)
- )
- } else {
- this.currentWorkerId =
- this.currentWorkerId === this.pool.workers.length - 1
- ? 0
- : this.currentWorkerId + 1
- this.setWorkerTaskRunTime(this.currentWorkerId, workerTaskWeight, 0)
- }
- return chosenWorkerKey