{
skipWords: [
'Benoit',
+ 'Uint8',
+ 'Uint16',
+ 'Uint32',
+ 'Uint64',
'benny',
'browserslist',
'builtins',
runTimeHistory: new CircularArray(),
avgRunTime: 0,
medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: new CircularArray(),
+ avgWaitTime: 0,
+ medWaitTime: 0,
error: 0
})
}
/** @inheritDoc */
public async execute (data?: Data, name?: string): Promise<Response> {
+ const submissionTimestamp = performance.now()
const workerNodeKey = this.chooseWorkerNode()
const submittedTask: Task<Data> = {
name,
// eslint-disable-next-line @typescript-eslint/consistent-type-assertions
data: data ?? ({} as Data),
+ submissionTimestamp,
id: crypto.randomUUID()
}
const res = new Promise<Response>((resolve, reject) => {
workerTasksUsage.medRunTime = median(workerTasksUsage.runTimeHistory)
}
}
+ if (this.workerChoiceStrategyContext.getRequiredStatistics().waitTime) {
+ workerTasksUsage.waitTime += message.waitTime ?? 0
+ if (
+ this.workerChoiceStrategyContext.getRequiredStatistics().avgWaitTime &&
+ workerTasksUsage.run !== 0
+ ) {
+ workerTasksUsage.avgWaitTime =
+ workerTasksUsage.waitTime / workerTasksUsage.run
+ }
+ if (
+ this.workerChoiceStrategyContext.getRequiredStatistics().medWaitTime &&
+ message.waitTime != null
+ ) {
+ workerTasksUsage.waitTimeHistory.push(message.waitTime)
+ workerTasksUsage.medWaitTime = median(workerTasksUsage.waitTimeHistory)
+ }
+ }
}
/**
runTimeHistory: new CircularArray(),
avgRunTime: 0,
medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: new CircularArray(),
+ avgWaitTime: 0,
+ medWaitTime: 0,
error: 0
},
tasksQueue: new Queue<Task<Data>>()
public readonly requiredStatistics: RequiredStatistics = {
runTime: false,
avgRunTime: false,
- medRunTime: false
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
}
/**
this.requiredStatistics.avgRunTime = true
this.requiredStatistics.medRunTime = opts.medRunTime as boolean
}
+ if (this.requiredStatistics.avgWaitTime && opts.medWaitTime === true) {
+ this.requiredStatistics.avgWaitTime = false
+ this.requiredStatistics.medWaitTime = opts.medWaitTime as boolean
+ }
+ if (this.requiredStatistics.medWaitTime && opts.medWaitTime === false) {
+ this.requiredStatistics.avgWaitTime = true
+ this.requiredStatistics.medWaitTime = opts.medWaitTime as boolean
+ }
}
/** @inheritDoc */
public readonly requiredStatistics: RequiredStatistics = {
runTime: true,
avgRunTime: true,
- medRunTime: false
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
}
/**
public readonly requiredStatistics: RequiredStatistics = {
runTime: true,
avgRunTime: false,
- medRunTime: false
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
}
/** @inheritDoc */
* @defaultValue false
*/
medRunTime?: boolean
+ /**
+ * Use tasks median wait time instead of average runtime.
+ *
+ * @defaultValue false
+ */
+ medWaitTime?: boolean
/**
* Worker weights to use for weighted round robin worker selection strategy.
* Weight is the tasks maximum average or median runtime in milliseconds.
* Require tasks median runtime.
*/
medRunTime: boolean
+ /**
+ * Require tasks wait time.
+ */
+ waitTime: boolean
+ /**
+ * Require tasks average wait time.
+ */
+ avgWaitTime: boolean
+ /**
+ * Require tasks median wait time.
+ */
+ medWaitTime: boolean
}
/**
public readonly requiredStatistics: RequiredStatistics = {
runTime: true,
avgRunTime: true,
- medRunTime: false
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
}
/**
* Task input data that will be passed to the worker.
*/
readonly data?: Data
+ /**
+ * Submission timestamp.
+ */
+ readonly submissionTimestamp?: number
/**
* Message UUID.
*/
* Median tasks runtime.
*/
medRunTime: number
+ /**
+ * Tasks wait time.
+ */
+ waitTime: number
+ /**
+ * Tasks wait time history.
+ */
+ waitTimeHistory: CircularArray<number>
+ /**
+ * Average tasks wait time.
+ */
+ avgWaitTime: number
+ /**
+ * Median tasks wait time.
+ */
+ medWaitTime: number
/**
* Number of tasks errored.
*/
* Runtime.
*/
readonly runTime?: number
+ /**
+ * Wait time.
+ */
+ readonly waitTime?: number
/**
* Reference to main worker.
*/
*/
export const DEFAULT_WORKER_CHOICE_STRATEGY_OPTIONS: WorkerChoiceStrategyOptions =
{
- medRunTime: false
+ medRunTime: false,
+ medWaitTime: false
}
/**
): void {
try {
const startTimestamp = performance.now()
+ const waitTime = startTimestamp - (message.submissionTimestamp ?? 0)
const res = fn(message.data)
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
id: message.id,
- runTime
+ runTime,
+ waitTime
})
} catch (e) {
const err = this.handleError(e as Error)
message: MessageValue<Data>
): void {
const startTimestamp = performance.now()
+ const waitTime = startTimestamp - (message.submissionTimestamp ?? 0)
fn(message.data)
.then(res => {
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
id: message.id,
- runTime
+ runTime,
+ waitTime
})
return null
})
WorkerChoiceStrategies.ROUND_ROBIN
)
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
- medRunTime: false
+ medRunTime: false,
+ medWaitTime: false
})
expect(pool.opts.messageHandler).toBeUndefined()
expect(pool.opts.errorHandler).toBeUndefined()
{ workerChoiceStrategy: WorkerChoiceStrategies.FAIR_SHARE }
)
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
- medRunTime: false
+ medRunTime: false,
+ medWaitTime: false
})
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
- expect(workerChoiceStrategy.opts).toStrictEqual({ medRunTime: false })
+ expect(workerChoiceStrategy.opts).toStrictEqual({
+ medRunTime: false,
+ medWaitTime: false
+ })
}
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: true,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
pool.setWorkerChoiceStrategyOptions({ medRunTime: true })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
medRunTime: true
expect(workerChoiceStrategy.opts).toStrictEqual({ medRunTime: true })
}
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(true)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: false,
+ medRunTime: true,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
pool.setWorkerChoiceStrategyOptions({ medRunTime: false })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
medRunTime: false
expect(workerChoiceStrategy.opts).toStrictEqual({ medRunTime: false })
}
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: true,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
await pool.destroy()
})
'./tests/worker-files/cluster/testWorker.js'
)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage).toBeDefined()
- expect(workerNode.tasksUsage.run).toBe(0)
- expect(workerNode.tasksUsage.running).toBe(0)
- expect(workerNode.tasksUsage.runTime).toBe(0)
- expect(workerNode.tasksUsage.runTimeHistory).toBeInstanceOf(CircularArray)
- expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
- expect(workerNode.tasksUsage.avgRunTime).toBe(0)
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
- expect(workerNode.tasksUsage.error).toBe(0)
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: 0,
+ running: 0,
+ runTime: 0,
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
}
await pool.destroy()
})
promises.push(pool.execute())
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage).toBeDefined()
- expect(workerNode.tasksUsage.run).toBe(0)
- expect(workerNode.tasksUsage.running).toBe(numberOfWorkers * 2)
- expect(workerNode.tasksUsage.runTime).toBe(0)
- expect(workerNode.tasksUsage.runTimeHistory).toBeInstanceOf(CircularArray)
- expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
- expect(workerNode.tasksUsage.avgRunTime).toBe(0)
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
- expect(workerNode.tasksUsage.error).toBe(0)
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: 0,
+ running: numberOfWorkers * 2,
+ runTime: 0,
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage).toBeDefined()
- expect(workerNode.tasksUsage.run).toBe(numberOfWorkers * 2)
- expect(workerNode.tasksUsage.running).toBe(0)
- expect(workerNode.tasksUsage.runTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.runTimeHistory).toBeInstanceOf(CircularArray)
- expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
- expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
- expect(workerNode.tasksUsage.error).toBe(0)
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: numberOfWorkers * 2,
+ running: 0,
+ runTime: 0,
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
}
await pool.destroy()
})
}
await Promise.all(promises)
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage).toBeDefined()
- expect(workerNode.tasksUsage.run).toBe(numberOfWorkers * 2)
- expect(workerNode.tasksUsage.running).toBe(0)
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: numberOfWorkers * 2,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.runTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.runTimeHistory).toBeInstanceOf(CircularArray)
- expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
- expect(workerNode.tasksUsage.error).toBe(0)
}
pool.setWorkerChoiceStrategy(WorkerChoiceStrategies.FAIR_SHARE)
for (const workerNode of pool.workerNodes) {
expect(workerNode.tasksUsage).toBeDefined()
- expect(workerNode.tasksUsage.run).toBe(0)
- expect(workerNode.tasksUsage.running).toBe(0)
- expect(workerNode.tasksUsage.runTime).toBe(0)
- expect(workerNode.tasksUsage.runTimeHistory).toBeInstanceOf(CircularArray)
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: 0,
+ running: 0,
+ runTime: 0,
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
- expect(workerNode.tasksUsage.avgRunTime).toBe(0)
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
- expect(workerNode.tasksUsage.error).toBe(0)
}
await pool.destroy()
})
FixedThreadPool,
FixedClusterPool
} = require('../../../lib')
+const { CircularArray } = require('../../../lib/circular-array')
describe('Selection strategies test suite', () => {
const min = 0
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: false,
+ avgRunTime: false,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
await pool.destroy()
pool = new DynamicThreadPool(
min,
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: false,
+ avgRunTime: false,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
// We need to clean up the resources after our test
await pool.destroy()
})
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: false,
+ avgRunTime: false,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
await pool.destroy()
pool = new DynamicThreadPool(
min,
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: false,
+ avgRunTime: false,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
// We need to clean up the resources after our test
await pool.destroy()
})
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: false,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
await pool.destroy()
pool = new DynamicThreadPool(
min,
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(false)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: false,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
// We need to clean up the resources after our test
await pool.destroy()
})
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: true,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
await pool.destroy()
pool = new DynamicThreadPool(
min,
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: true,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
// We need to clean up the resources after our test
await pool.destroy()
})
await pool.execute()
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage.avgRunTime).toBeDefined()
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: maxMultiplier,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: expect.any(Number),
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.medRunTime).toBeDefined()
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
await pool.execute()
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage.avgRunTime).toBeDefined()
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: max * maxMultiplier,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: expect.any(Number),
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.medRunTime).toBeDefined()
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
await pool.execute()
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage.avgRunTime).toBeDefined()
- expect(workerNode.tasksUsage.avgRunTime).toBe(0)
- expect(workerNode.tasksUsage.medRunTime).toBeDefined()
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: max * maxMultiplier,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: expect.any(Number),
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.medRunTime).toBeGreaterThanOrEqual(0)
}
expect(
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: true,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
await pool.destroy()
pool = new DynamicThreadPool(
min,
{ workerChoiceStrategy }
)
expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().runTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().avgRunTime
- ).toBe(true)
- expect(
- pool.workerChoiceStrategyContext.getRequiredStatistics().medRunTime
- ).toBe(false)
+ pool.workerChoiceStrategyContext.getRequiredStatistics()
+ ).toStrictEqual({
+ runTime: true,
+ avgRunTime: true,
+ medRunTime: false,
+ waitTime: false,
+ avgWaitTime: false,
+ medWaitTime: false
+ })
// We need to clean up the resources after our test
await pool.destroy()
})
await pool.execute()
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage.avgRunTime).toBeDefined()
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: max * maxMultiplier,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: expect.any(Number),
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.medRunTime).toBeDefined()
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
await pool.execute()
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage.avgRunTime).toBeDefined()
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: max * maxMultiplier,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: expect.any(Number),
+ medRunTime: 0,
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.avgRunTime).toBeGreaterThanOrEqual(0)
- expect(workerNode.tasksUsage.medRunTime).toBeDefined()
- expect(workerNode.tasksUsage.medRunTime).toBe(0)
}
expect(
pool.workerChoiceStrategyContext.workerChoiceStrategies.get(
await pool.execute()
}
for (const workerNode of pool.workerNodes) {
- expect(workerNode.tasksUsage.avgRunTime).toBeDefined()
- expect(workerNode.tasksUsage.avgRunTime).toBe(0)
- expect(workerNode.tasksUsage.medRunTime).toBeDefined()
+ expect(workerNode.tasksUsage).toStrictEqual({
+ run: max * maxMultiplier,
+ running: 0,
+ runTime: expect.any(Number),
+ runTimeHistory: expect.any(CircularArray),
+ avgRunTime: 0,
+ medRunTime: expect.any(Number),
+ waitTime: 0,
+ waitTimeHistory: expect.any(CircularArray),
+ avgWaitTime: 0,
+ medWaitTime: 0,
+ error: 0
+ })
expect(workerNode.tasksUsage.medRunTime).toBeGreaterThanOrEqual(0)
}
expect(