queuePool.opts.tasksQueueOptions.concurrency
)
expect(workerNode.workerUsage.tasks.executed).toBe(0)
- expect(workerNode.tasksQueue.size).toBeGreaterThan(0)
+ expect(workerNode.workerUsage.tasks.queued).toBeGreaterThan(0)
}
expect(queuePool.info.executingTasks).toBe(numberOfThreads)
expect(queuePool.info.queuedTasks).toBe(
expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
maxMultiplier
)
- expect(workerNode.tasksQueue.size).toBe(0)
+ expect(workerNode.workerUsage.tasks.queued).toBe(0)
}
})
})
it('Shutdown test', async () => {
- const exitPromise = TestUtils.waitWorkerExits(pool, numberOfThreads)
+ const exitPromise = TestUtils.waitWorkerEvents(
+ pool,
+ 'exit',
+ numberOfThreads
+ )
await pool.destroy()
const numberOfExitEvents = await exitPromise
expect(numberOfExitEvents).toBe(numberOfThreads)