- public choose (): Worker {
- let chosenWorker = this.pool.workers[this.currentWorkerIndex]
- if (
- this.isDynamicPool === true &&
- this.workersTaskRunTime.has(chosenWorker) === false
- ) {
- this.initWorkerTaskRunTime(chosenWorker)
- }
- const workerTaskWeight =
- this.workersTaskRunTime.get(chosenWorker)?.weight ??
- this.defaultWorkerWeight
- if (
- (this.workersTaskRunTime.get(chosenWorker)?.runTime ?? 0) <
- workerTaskWeight
- ) {
- this.setWorkerTaskRunTime(
- chosenWorker,
- workerTaskWeight,
- (this.workersTaskRunTime.get(chosenWorker)?.runTime ?? 0) +
- (this.getWorkerVirtualTaskRunTime(chosenWorker) ?? 0)
- )
- } else {
- this.currentWorkerIndex =
- this.pool.workers.length - 1 === this.currentWorkerIndex
- ? 0
- : this.currentWorkerIndex + 1
- chosenWorker = this.pool.workers[this.currentWorkerIndex]
- this.setWorkerTaskRunTime(chosenWorker, workerTaskWeight, 0)
- }
- return chosenWorker
- }
-
- private initWorkersTaskRunTime (): void {
- for (const worker of this.pool.workers) {
- this.initWorkerTaskRunTime(worker)
- }
- }
-
- private initWorkerTaskRunTime (worker: Worker): void {
- this.setWorkerTaskRunTime(worker, this.defaultWorkerWeight, 0)