- 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()
- })
-