FixedClusterPool
} = require('../../../lib')
const { CircularArray } = require('../../../lib/circular-array')
+const TestUtils = require('../../test-utils')
describe('Selection strategies test suite', () => {
const min = 0
runTime: true,
avgRunTime: false,
medRunTime: false,
- waitTime: false,
+ waitTime: true,
avgWaitTime: false,
medWaitTime: false,
elu: false
runTime: true,
avgRunTime: false,
medRunTime: false,
- waitTime: false,
+ waitTime: true,
avgWaitTime: false,
medWaitTime: false,
elu: false
history: expect.any(CircularArray)
},
waitTime: {
- aggregation: 0,
+ aggregation: expect.any(Number),
average: 0,
median: 0,
history: expect.any(CircularArray)
expect(workerNode.workerUsage.runTime.aggregation).toBeGreaterThanOrEqual(
0
)
+ expect(
+ workerNode.workerUsage.waitTime.aggregation
+ ).toBeGreaterThanOrEqual(0)
}
// We need to clean up the resources after our test
await pool.destroy()
history: expect.any(CircularArray)
},
waitTime: {
- aggregation: 0,
+ aggregation: expect.any(Number),
average: 0,
median: 0,
history: expect.any(CircularArray)
max * maxMultiplier
)
expect(workerNode.workerUsage.runTime.aggregation).toBeGreaterThan(0)
+ expect(workerNode.workerUsage.waitTime.aggregation).toBeGreaterThan(0)
}
// We need to clean up the resources after our test
await pool.destroy()
await pool.destroy()
})
+ it('Verify LEAST_ELU strategy can be run in a fixed pool', async () => {
+ const pool = new FixedThreadPool(
+ max,
+ './tests/worker-files/thread/testWorker.js',
+ { workerChoiceStrategy: WorkerChoiceStrategies.LEAST_ELU }
+ )
+ // TODO: Create a better test to cover `LeastEluWorkerChoiceStrategy#choose`
+ const maxMultiplier = 2
+ for (let i = 0; i < max * maxMultiplier; i++) {
+ await pool.execute()
+ if (i !== max * maxMultiplier - 1) await TestUtils.sleep(500)
+ }
+ for (const workerNode of pool.workerNodes) {
+ const expectedWorkerUsage = {
+ tasks: {
+ executed: expect.any(Number),
+ executing: 0,
+ queued: 0,
+ failed: 0
+ },
+ runTime: {
+ aggregation: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ },
+ waitTime: {
+ aggregation: 0,
+ average: 0,
+ median: 0,
+ history: expect.any(CircularArray)
+ }
+ }
+ if (workerNode.workerUsage.elu === undefined) {
+ expect(workerNode.workerUsage).toStrictEqual({
+ ...expectedWorkerUsage,
+ elu: undefined
+ })
+ } else {
+ expect(workerNode.workerUsage).toStrictEqual({
+ ...expectedWorkerUsage,
+ elu: {
+ active: expect.any(Number),
+ idle: 0,
+ utilization: 1
+ }
+ })
+ }
+ expect(workerNode.workerUsage.tasks.executed).toBeGreaterThanOrEqual(0)
+ expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
+ max * maxMultiplier
+ )
+ }
+ // We need to clean up the resources after our test
+ await pool.destroy()
+ })
+
it('Verify FAIR_SHARE strategy default tasks usage statistics requirements', async () => {
const workerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE
let pool = new FixedThreadPool(