X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Ffixed.test.js;h=0c3ba276f3b4e40c4d2d40e2a5484efd679cb094;hb=2cf93bc8e7b3d9c6c642288939732edd7cd9142d;hp=aed2b3c193ffe90977fa9f853aa670f0eaff51b5;hpb=5dd39e0fba309bb3af0ca64aea5205f57dfe5d24;p=poolifier.git diff --git a/tests/pools/thread/fixed.test.js b/tests/pools/thread/fixed.test.js index aed2b3c1..0c3ba276 100644 --- a/tests/pools/thread/fixed.test.js +++ b/tests/pools/thread/fixed.test.js @@ -89,8 +89,8 @@ describe('Fixed thread pool test suite', () => { }) it('Verify that tasks queuing is working', async () => { - const maxMultiplier = 10 const promises = new Set() + const maxMultiplier = 2 for (let i = 0; i < numberOfThreads * maxMultiplier; i++) { promises.add(queuePool.execute()) } @@ -110,6 +110,7 @@ describe('Fixed thread pool test suite', () => { for (const workerNode of queuePool.workerNodes) { expect(workerNode.tasksUsage.running).toBe(0) expect(workerNode.tasksUsage.run).toBeGreaterThan(0) + expect(workerNode.tasksUsage.run).toBeLessThanOrEqual(maxMultiplier) expect(workerNode.tasksQueue.size).toBe(0) } promises.clear()