expect(pool.workerChoiceStrategyContext.workerChoiceStrategy).toBe(
workerChoiceStrategy
)
- expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
- retries: 6,
- runTime: { median: false },
- waitTime: { median: false },
- elu: { median: false }
- })
+ expect(pool.opts.workerChoiceStrategyOptions).toBeUndefined()
expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: 6,
+ retries: pool.info.maxSize,
runTime: { median: false },
waitTime: { median: false },
elu: { median: false }
max,
'./tests/worker-files/cluster/testWorker.js'
)
- pool.setWorkerChoiceStrategy(workerChoiceStrategy, { retries: 3 })
+ pool.setWorkerChoiceStrategy(workerChoiceStrategy)
expect(pool.opts.workerChoiceStrategy).toBe(workerChoiceStrategy)
expect(pool.workerChoiceStrategyContext.workerChoiceStrategy).toBe(
workerChoiceStrategy
)
- expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
- retries: 3,
- runTime: { median: false },
- waitTime: { median: false },
- elu: { median: false }
- })
+ expect(pool.opts.workerChoiceStrategyOptions).toBeUndefined()
expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: 3,
+ retries: pool.info.maxSize,
runTime: { median: false },
waitTime: { median: false },
elu: { median: false }
await pool.destroy()
})
+ it('Verify strategies wait for worker node readiness in dynamic pool', async () => {
+ const pool = new DynamicThreadPool(
+ min,
+ max,
+ './tests/worker-files/thread/testWorker.mjs'
+ )
+ expect(pool.starting).toBe(false)
+ expect(pool.workerNodes.length).toBe(min)
+ const maxMultiplier = 10000
+ const promises = new Set()
+ for (let i = 0; i < max * maxMultiplier; i++) {
+ promises.add(pool.execute())
+ }
+ await Promise.all(promises)
+ expect(pool.workerNodes.length).toBe(max)
+ // We need to clean up the resources after our test
+ await pool.destroy()
+ })
+
it('Verify ROUND_ROBIN strategy default policy', async () => {
const workerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN
let pool = new FixedThreadPool(
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: {
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({
executing: 0,
queued: 0,
maxQueued: 0,
- stolen: 0,
sequentiallyStolen: 0,
+ stolen: 0,
failed: 0
},
runTime: expect.objectContaining({