expect(workerNode.usage.tasks.maxQueued).toBe(
maxMultiplier - queuePool.opts.tasksQueueOptions.concurrency
)
+ expect(workerNode.usage.tasks.sequentiallyStolen).toBe(0)
expect(workerNode.usage.tasks.stolen).toBe(0)
}
expect(queuePool.info.executedTasks).toBe(0)
expect(workerNode.usage.tasks.maxQueued).toBe(
maxMultiplier - queuePool.opts.tasksQueueOptions.concurrency
)
+ expect(workerNode.usage.tasks.sequentiallyStolen).toBeGreaterThanOrEqual(
+ 0
+ )
+ expect(workerNode.usage.tasks.sequentiallyStolen).toBeLessThanOrEqual(
+ numberOfWorkers * maxMultiplier
+ )
expect(workerNode.usage.tasks.stolen).toBeGreaterThanOrEqual(0)
expect(workerNode.usage.tasks.stolen).toBeLessThanOrEqual(
numberOfWorkers * maxMultiplier
await pool.destroy()
const numberOfExitEvents = await exitPromise
expect(pool.started).toBe(false)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
+ expect(pool.readyEventEmitted).toBe(false)
expect(pool.workerNodes.length).toBe(0)
expect(numberOfExitEvents).toBe(numberOfWorkers)
expect(poolDestroy).toBe(1)