medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
pool.setWorkerChoiceStrategyOptions({ medRunTime: true })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
medRunTime: true,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
pool.setWorkerChoiceStrategyOptions({ medRunTime: false })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
})
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
await Promise.all(promises)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThan(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(maxMultiplier)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
expect(workerNode.tasksUsage.waitTimeHistory.length).toBe(0)
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
// We need to clean up the resources after our test
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
expect(
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
expect(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
// We need to clean up the resources after our test
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
// We need to clean up the resources after our test
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
// We need to clean up the resources after our test
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
// We need to clean up the resources after our test
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThan(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(max * maxMultiplier)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThan(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(max * maxMultiplier)
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
// We need to clean up the resources after our test
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.runTime).toBeGreaterThan(0)
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThan(0)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.runTime).toBeGreaterThan(0)
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThan(0)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.runTime).toBeGreaterThan(0)
expect(workerNode.tasksUsage.medRunTime).toBeGreaterThan(0)
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
// We need to clean up the resources after our test
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThanOrEqual(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(max * maxMultiplier)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThan(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(max * maxMultiplier)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThan(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(max * maxMultiplier)
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
// We need to clean up the resources after our test
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
expect(
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
expect(