X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Fdynamic.test.js;h=241a1b60ce312a77dd265e3d1390ae6e25ab5786;hb=767e23e80a540dcedab8a2aa5203b8526e3df7b1;hp=31d64727707d3bc4c31b14501fbe4b41e81aa2fb;hpb=292ad316a2815762f2e4a822383f1aef5ae49774;p=poolifier.git diff --git a/tests/pools/thread/dynamic.test.js b/tests/pools/thread/dynamic.test.js index 31d64727..241a1b60 100644 --- a/tests/pools/thread/dynamic.test.js +++ b/tests/pools/thread/dynamic.test.js @@ -27,7 +27,9 @@ describe('Dynamic thread pool test suite', () => { promises.push(pool.execute({ test: 'test' })) } expect(pool.workers.length).toBe(max) - expect(poolBusy).toEqual(max + 1) + // The `busy` event is triggered when the number of submitted tasks at once reach the max number of workers in the dynamic pool. + // So in total numberOfWorkers + 1 times for a loop submitting up to numberOfWorkers * 2 tasks to the dynamic pool. + expect(poolBusy).toBe(max + 1) const res = await TestUtils.waitExits(pool, max - min) expect(res).toBe(max - min) }) @@ -72,6 +74,7 @@ describe('Dynamic thread pool test suite', () => { './tests/worker-files/thread/testWorker.js' ) const res = await pool1.execute({ test: 'test' }) + expect(res).toBeDefined() expect(res).toBeFalsy() // We need to clean up the resources after our test await pool1.destroy()