- const workerDeleted = this.workersTaskRunTime.delete(workerKey)
- for (const [key, value] of this.workersTaskRunTime) {
- if (key > workerKey) {
- this.workersTaskRunTime.set(key - 1, value)
- }
- }
- return workerDeleted
- }
-
- private initWorkersTaskRunTime (): void {
- for (const [index] of this.pool.workers.entries()) {
- this.initWorkerTaskRunTime(index)
- }
- }
-
- private initWorkerTaskRunTime (workerKey: number): void {
- this.setWorkerTaskRunTime(workerKey, this.defaultWorkerWeight, 0)
- }
-
- private setWorkerTaskRunTime (
- workerKey: number,
- weight: number,
- runTime: number
- ): void {
- this.workersTaskRunTime.set(workerKey, {
- weight,
- runTime
- })
- }
-
- private getWorkerVirtualTaskRunTime (workerKey: number): number {
- return this.pool.workers[workerKey].tasksUsage.avgRunTime