X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fthread%2Ffixed.test.mjs;h=3da05735588953cf6c0882a30aa86a231dd8b841;hb=b1d4f434444dd51c9006ab9b515d717c3d7f27a8;hp=94f7921caccb07d0474952a85c77e440d9d3fa0f;hpb=ea4b5fd037c5fe09eb6a2810332ad6bed1b5bc7f;p=poolifier.git diff --git a/tests/pools/thread/fixed.test.mjs b/tests/pools/thread/fixed.test.mjs index 94f7921c..3da05735 100644 --- a/tests/pools/thread/fixed.test.mjs +++ b/tests/pools/thread/fixed.test.mjs @@ -68,7 +68,7 @@ describe('Fixed 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 }) @@ -301,7 +301,10 @@ describe('Fixed 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(numberOfThreads) @@ -345,7 +348,8 @@ describe('Fixed thread pool test suite', () => { }) await expect(pool.destroyWorkerNode(workerNodeKey)).resolves.toBeUndefined() expect(exitEvent).toBe(1) - expect(pool.workerNodes.length).toBe(numberOfThreads - 1) + // Simulates an illegitimate worker node destroy and the minimum number of worker nodes is guaranteed + expect(pool.workerNodes.length).toBe(numberOfThreads) await pool.destroy() })