-
- /**
- * Check the next worker node eligibility.
- */
- protected checkNextWorkerNodeEligibility (): void {
- if (!this.isWorkerNodeEligible(this.nextWorkerNodeKey as number)) {
- delete this.nextWorkerNodeKey
- }
- }
-
- protected computeDefaultWorkerWeight (): number {
- let cpusCycleTimeWeight = 0
- for (const cpu of cpus()) {
- // CPU estimated cycle time
- const numberOfDigits = cpu.speed.toString().length - 1
- const cpuCycleTime = 1 / (cpu.speed / Math.pow(10, numberOfDigits))
- cpusCycleTimeWeight += cpuCycleTime * Math.pow(10, numberOfDigits)
- }
- return Math.round(cpusCycleTimeWeight / cpus().length)
- }