X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Ffixed.test.js;h=e160f17c72b6d4db2e8111d7fed488f84a666610;hb=eb3b4c1592abc3f91acfe98c236a02ca994febff;hp=ec6a066bf8c0042cc2ff21a7e9345f87416b72a9;hpb=515e5da7461f84786a9b6acf859cf65a083e2f4c;p=poolifier.git diff --git a/tests/pools/thread/fixed.test.js b/tests/pools/thread/fixed.test.js index ec6a066b..e160f17c 100644 --- a/tests/pools/thread/fixed.test.js +++ b/tests/pools/thread/fixed.test.js @@ -1,13 +1,12 @@ const expect = require('expect') const { FixedThreadPool } = require('../../../lib/index') -const numThreads = 10 +const numberOfThreads = 10 const maxTasks = 400 const pool = new FixedThreadPool( - numThreads, + numberOfThreads, './tests/worker/thread/testWorker.js', { - errorHandler: e => console.error(e), - onlineHandler: () => console.log('worker is online') + errorHandler: e => console.error(e) } ) const emptyPool = new FixedThreadPool(1, './tests/worker/thread/emptyWorker.js') @@ -29,10 +28,10 @@ const asyncPool = new FixedThreadPool( describe('Fixed thread pool test suite ', () => { it('Choose worker round robin test', async () => { const results = new Set() - for (let i = 0; i < numThreads; i++) { + for (let i = 0; i < numberOfThreads; i++) { results.add(pool.chooseWorker().threadId) } - expect(results.size).toBe(numThreads) + expect(results.size).toBe(numberOfThreads) }) it('Verify that the function is executed in a worker thread', async () => { @@ -95,7 +94,7 @@ describe('Fixed thread pool test suite ', () => { }) }) await pool.destroy() - expect(closedThreads).toBe(numThreads) + expect(closedThreads).toBe(numberOfThreads) }) it('Validations test', () => {