executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: maxMultiplier,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
+ stolen: 0,
failed: 0
},
runTime: {
++poolBackPressure
poolInfo = info
})
- for (let i = 0; i < numberOfWorkers * 2; i++) {
+ for (let i = 0; i < numberOfWorkers + 1; i++) {
promises.add(pool.execute())
}
await Promise.all(promises)
- expect(poolBackPressure).toBe(2)
+ expect(poolBackPressure).toBe(1)
expect(poolInfo).toStrictEqual({
version,
type: PoolTypes.fixed,
maxQueuedTasks: expect.any(Number),
queuedTasks: expect.any(Number),
backPressure: true,
+ stolenTasks: expect.any(Number),
failedTasks: expect.any(Number)
})
expect(pool.hasBackPressure.called).toBe(true)
executed: expect.any(Number),
executing: expect.any(Number),
failed: 0,
- queued: 0
+ queued: 0,
+ stolen: 0
},
runTime: {
history: expect.any(CircularArray)