X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Fdynamic.test.js;h=ac926a927a2c22f11a8b82c95785c8658210cfe5;hb=1ab67a38cefe2215f89285c2fb6517247b1eef74;hp=4f3dfb6d92f0a761a8cfbc766a91fde55b1c29b8;hpb=9b1068374b1a52479b07e1e22b692289d5579237;p=poolifier.git diff --git a/tests/pools/thread/dynamic.test.js b/tests/pools/thread/dynamic.test.js index 4f3dfb6d..ac926a92 100644 --- a/tests/pools/thread/dynamic.test.js +++ b/tests/pools/thread/dynamic.test.js @@ -1,6 +1,6 @@ const { expect } = require('expect') const { DynamicThreadPool, PoolEvents } = require('../../../lib') -const { WorkerFunctions } = require('../../test-types') +const { TaskFunctions } = require('../../test-types') const { sleep, waitWorkerEvents } = require('../../test-utils') describe('Dynamic thread pool test suite', () => { @@ -17,11 +17,11 @@ describe('Dynamic thread pool test suite', () => { it('Verify that the function is executed in a worker thread', async () => { let result = await pool.execute({ - function: WorkerFunctions.fibonacci + function: TaskFunctions.fibonacci }) expect(result).toBe(75025) result = await pool.execute({ - function: WorkerFunctions.factorial + function: TaskFunctions.factorial }) expect(result).toBe(9.33262154439441e157) }) @@ -89,8 +89,8 @@ describe('Dynamic thread pool test suite', () => { './tests/worker-files/thread/longRunningWorkerHardBehavior.js', { errorHandler: e => console.error(e), - onlineHandler: () => console.log('long executing worker is online'), - exitHandler: () => console.log('long executing worker exited') + onlineHandler: () => console.info('long executing worker is online'), + exitHandler: () => console.info('long executing worker exited') } ) expect(longRunningPool.workerNodes.length).toBe(min) @@ -116,8 +116,8 @@ describe('Dynamic thread pool test suite', () => { './tests/worker-files/thread/longRunningWorkerSoftBehavior.js', { errorHandler: e => console.error(e), - onlineHandler: () => console.log('long executing worker is online'), - exitHandler: () => console.log('long executing worker exited') + onlineHandler: () => console.info('long executing worker is online'), + exitHandler: () => console.info('long executing worker exited') } ) expect(longRunningPool.workerNodes.length).toBe(min)