+ /**
+ * Gets the worker task runtime.
+ * If the task statistics require `avgRunTime`, the average runtime is returned.
+ * If the task statistics require `medRunTime`, the median runtime is returned.
+ *
+ * @param workerNodeKey - The worker node key.
+ * @returns The worker task runtime.
+ */
+ protected getWorkerTaskRunTime (workerNodeKey: number): number {
+ return this.taskStatisticsRequirements.medRunTime
+ ? this.pool.workerNodes[workerNodeKey].workerUsage.runTime.median
+ : this.pool.workerNodes[workerNodeKey].workerUsage.runTime.average
+ }
+
+ /**
+ * Gets the worker task wait time.
+ * If the task statistics require `avgWaitTime`, the average wait time is returned.
+ * If the task statistics require `medWaitTime`, the median wait time is returned.
+ *
+ * @param workerNodeKey - The worker node key.
+ * @returns The worker task wait time.
+ */
+ protected getWorkerWaitTime (workerNodeKey: number): number {
+ return this.taskStatisticsRequirements.medWaitTime
+ ? this.pool.workerNodes[workerNodeKey].workerUsage.runTime.median
+ : this.pool.workerNodes[workerNodeKey].workerUsage.runTime.average
+ }
+
+ 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)
+ }
+