'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: false,
avgRunTime: false,
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: false,
avgRunTime: false,
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(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: false,
avgRunTime: false,
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: false,
avgRunTime: false,
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
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: true,
avgRunTime: false,
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: true,
avgRunTime: false,
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)
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: true,
avgRunTime: true,
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: true,
avgRunTime: true,
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)
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: true,
avgRunTime: true,
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: true,
avgRunTime: true,
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)
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: false,
avgRunTime: false,
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
pool = new DynamicThreadPool(
'./tests/worker-files/thread/testWorker.js',
{ workerChoiceStrategy }
)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics()
- ).toStrictEqual({
+ expect(pool.workerChoiceStrategyContext.getTaskStatistics()).toStrictEqual({
runTime: false,
avgRunTime: false,
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(