X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Fdynamic.test.mjs;h=22d89223f337c0d7a714811fa3b37c09ecd6b861;hb=b1a6445cf82a7c06495f1ec774fb7b04fb7f9336;hp=77c5aaeb5afd3893c8c7eb265a7d65ed4d3cdda6;hpb=e372f3935374fbbea3a5d3acc72813b36ced86ff;p=poolifier.git diff --git a/tests/pools/thread/dynamic.test.mjs b/tests/pools/thread/dynamic.test.mjs index 77c5aaeb..22d89223 100644 --- a/tests/pools/thread/dynamic.test.mjs +++ b/tests/pools/thread/dynamic.test.mjs @@ -1,4 +1,5 @@ import { expect } from 'expect' + import { DynamicThreadPool, PoolEvents, @@ -23,7 +24,7 @@ describe('Dynamic thread pool test suite', () => { let result = await pool.execute({ function: TaskFunctions.fibonacci }) - expect(result).toBe(75025) + expect(result).toBe(354224848179262000000) result = await pool.execute({ function: TaskFunctions.factorial }) @@ -71,7 +72,10 @@ describe('Dynamic thread pool test suite', () => { await pool.destroy() const numberOfExitEvents = await exitPromise expect(pool.started).toBe(false) - expect(pool.emitter.eventNames()).toStrictEqual([]) + expect(pool.emitter.eventNames()).toStrictEqual([ + PoolEvents.busy, + PoolEvents.destroy + ]) expect(pool.readyEventEmitted).toBe(false) expect(pool.workerNodes.length).toBe(0) expect(numberOfExitEvents).toBe(min) @@ -115,8 +119,9 @@ describe('Dynamic thread pool test suite', () => { await waitWorkerEvents(longRunningPool, 'exit', max - min) expect(longRunningPool.workerNodes.length).toBe(min) expect( - longRunningPool.workerChoiceStrategyContext.workerChoiceStrategies.get( - longRunningPool.workerChoiceStrategyContext.workerChoiceStrategy + longRunningPool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + longRunningPool.workerChoiceStrategiesContext + .defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toBeLessThan(longRunningPool.workerNodes.length) // We need to clean up the resources after our test