X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fselection-strategies%2Fselection-strategies.test.mjs;h=0e7f19fbdf0abe23685f31059328caa975ced2a3;hb=2717674c56c2caae531507e7d4e0068f4d4c8918;hp=e0eec68b714a3152e49ed6bfd3e26d50a06e8584;hpb=b2fd3f4a217ac09110da00b3b65dcdd36de4bf74;p=poolifier.git diff --git a/tests/pools/selection-strategies/selection-strategies.test.mjs b/tests/pools/selection-strategies/selection-strategies.test.mjs index e0eec68b..0e7f19fb 100644 --- a/tests/pools/selection-strategies/selection-strategies.test.mjs +++ b/tests/pools/selection-strategies/selection-strategies.test.mjs @@ -1,12 +1,15 @@ +import { randomInt } from 'node:crypto' + import { expect } from 'expect' + +import { CircularArray } from '../../../lib/circular-array.cjs' import { DynamicClusterPool, DynamicThreadPool, FixedClusterPool, FixedThreadPool, WorkerChoiceStrategies -} from '../../../lib/index.js' -import { CircularArray } from '../../../lib/circular-array.js' +} from '../../../lib/index.cjs' describe('Selection strategies test suite', () => { const min = 0 @@ -35,6 +38,9 @@ describe('Selection strategies test suite', () => { expect(pool.opts.workerChoiceStrategy).toBe( WorkerChoiceStrategies.ROUND_ROBIN ) + expect(pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy).toBe( + WorkerChoiceStrategies.ROUND_ROBIN + ) // We need to clean up the resources after our test await pool.destroy() }) @@ -47,9 +53,9 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect(pool.opts.workerChoiceStrategy).toBe(workerChoiceStrategy) - expect(pool.workerChoiceStrategyContext.workerChoiceStrategy).toBe( - workerChoiceStrategy - ) + expect( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).toBe(workerChoiceStrategy) await pool.destroy() } }) @@ -63,63 +69,40 @@ describe('Selection strategies test suite', () => { ) pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect(pool.opts.workerChoiceStrategy).toBe(workerChoiceStrategy) - expect(pool.workerChoiceStrategyContext.workerChoiceStrategy).toBe( - workerChoiceStrategy - ) - expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({ - retries: 6, - runTime: { median: false }, - waitTime: { median: false }, - elu: { median: false } - }) - expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({ - retries: 6, - runTime: { median: false }, - waitTime: { median: false }, - elu: { median: false } - }) + expect( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).toBe(workerChoiceStrategy) await pool.destroy() } for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) { const pool = new DynamicClusterPool( min, max, - './tests/worker-files/cluster/testWorker.js' + './tests/worker-files/cluster/testWorker.cjs' ) - pool.setWorkerChoiceStrategy(workerChoiceStrategy, { retries: 3 }) + pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect(pool.opts.workerChoiceStrategy).toBe(workerChoiceStrategy) - expect(pool.workerChoiceStrategyContext.workerChoiceStrategy).toBe( - workerChoiceStrategy - ) - expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({ - retries: 3, - runTime: { median: false }, - waitTime: { median: false }, - elu: { median: false } - }) - expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({ - retries: 3, - runTime: { median: false }, - waitTime: { median: false }, - elu: { median: false } - }) + expect( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).toBe(workerChoiceStrategy) await pool.destroy() } }) it('Verify available strategies default internals at pool creation', async () => { - const pool = new FixedThreadPool( - max, - './tests/worker-files/thread/testWorker.mjs' - ) for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) { + const pool = new FixedThreadPool( + max, + './tests/worker-files/thread/testWorker.mjs', + { workerChoiceStrategy } + ) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy ).nextWorkerNodeKey ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy ).previousWorkerNodeKey ).toBe(0) @@ -127,12 +110,7 @@ describe('Selection strategies test suite', () => { workerChoiceStrategy === WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN ) { expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy ).workerNodeVirtualTaskRunTime ).toBe(0) @@ -141,37 +119,35 @@ describe('Selection strategies test suite', () => { WorkerChoiceStrategies.INTERLEAVED_WEIGHTED_ROUND_ROBIN ) { expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy ).workerNodeVirtualTaskRunTime ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy ).roundId ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy ).workerNodeId ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).roundWeights - ).toStrictEqual([ - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( workerChoiceStrategy - ).defaultWorkerWeight - ]) + ).roundWeights.length + ).toBe(1) + expect( + Number.isSafeInteger( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).roundWeights[0] + ) + ).toBe(true) } + await pool.destroy() } - await pool.destroy() }) it('Verify ROUND_ROBIN strategy default policy', async () => { @@ -181,7 +157,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -192,7 +168,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -208,7 +184,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: false, @@ -234,7 +210,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: false, @@ -277,6 +253,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -297,13 +274,13 @@ describe('Selection strategies test suite', () => { }) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toBe(pool.workerNodes.length - 1) // We need to clean up the resources after our test @@ -332,6 +309,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -356,13 +334,13 @@ describe('Selection strategies test suite', () => { ) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toBe(pool.workerNodes.length - 1) // We need to clean up the resources after our test @@ -373,12 +351,12 @@ describe('Selection strategies test suite', () => { const workerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN let pool = new FixedClusterPool( max, - './tests/worker-files/cluster/testWorker.js', + './tests/worker-files/cluster/testWorker.cjs', { workerChoiceStrategy } ) let results = new Set() for (let i = 0; i < max; i++) { - results.add(pool.workerNodes[pool.chooseWorkerNode()].worker.id) + results.add(pool.workerNodes[pool.chooseWorkerNode()].info.id) } expect(results.size).toBe(max) await pool.destroy() @@ -389,68 +367,60 @@ describe('Selection strategies test suite', () => { ) results = new Set() for (let i = 0; i < max; i++) { - results.add(pool.workerNodes[pool.chooseWorkerNode()].worker.threadId) + results.add(pool.workerNodes[pool.chooseWorkerNode()].info.id) } expect(results.size).toBe(max) await pool.destroy() }) - it('Verify ROUND_ROBIN strategy internals are resets after setting it', async () => { + it("Verify ROUND_ROBIN strategy internals aren't reset after setting it", async () => { const workerChoiceStrategy = WorkerChoiceStrategies.ROUND_ROBIN let pool = new FixedThreadPool( max, './tests/worker-files/thread/testWorker.mjs', - { workerChoiceStrategy: WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN } + { workerChoiceStrategy } ) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).nextWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).previousWorkerNodeKey - ).toBeDefined() + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).nextWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).previousWorkerNodeKey = randomInt(1, max - 1) pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) await pool.destroy() pool = new DynamicThreadPool( min, max, './tests/worker-files/thread/testWorker.mjs', - { workerChoiceStrategy: WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN } + { workerChoiceStrategy } ) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).nextWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).previousWorkerNodeKey - ).toBeDefined() + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).nextWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).previousWorkerNodeKey = randomInt(1, max - 1) pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) // We need to clean up the resources after our test await pool.destroy() }) @@ -462,7 +432,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -473,7 +443,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -489,7 +459,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: false, @@ -515,7 +485,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: false, @@ -557,6 +527,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -581,13 +552,13 @@ describe('Selection strategies test suite', () => { ) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -615,6 +586,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -639,13 +611,13 @@ describe('Selection strategies test suite', () => { ) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -659,7 +631,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -670,7 +642,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -686,7 +658,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -712,7 +684,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -754,6 +726,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -788,13 +761,13 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -822,6 +795,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -856,13 +830,13 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -876,7 +850,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -887,7 +861,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -903,7 +877,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: false, @@ -929,7 +903,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: false, @@ -971,6 +945,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1011,13 +986,13 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -1045,6 +1020,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1085,13 +1061,13 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -1105,7 +1081,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -1116,7 +1092,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -1132,7 +1108,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -1158,7 +1134,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -1200,6 +1176,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1251,13 +1228,13 @@ describe('Selection strategies test suite', () => { expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -1285,6 +1262,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1336,13 +1314,13 @@ describe('Selection strategies test suite', () => { expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test @@ -1375,6 +1353,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1426,20 +1405,20 @@ describe('Selection strategies test suite', () => { expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toEqual(expect.any(Number)) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey ).toEqual(expect.any(Number)) // We need to clean up the resources after our test await pool.destroy() }) - it('Verify FAIR_SHARE strategy internals are resets after setting it', async () => { + it("Verify FAIR_SHARE strategy internals aren't reset after setting it", async () => { const workerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE let pool = new FixedThreadPool( max, @@ -1452,7 +1431,7 @@ describe('Selection strategies test suite', () => { } pool.setWorkerChoiceStrategy(workerChoiceStrategy) for (const workerNode of pool.workerNodes) { - expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeUndefined() + expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0) } await pool.destroy() pool = new DynamicThreadPool( @@ -1467,7 +1446,7 @@ describe('Selection strategies test suite', () => { } pool.setWorkerChoiceStrategy(workerChoiceStrategy) for (const workerNode of pool.workerNodes) { - expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeUndefined() + expect(workerNode.strategyData.virtualTaskEndTimestamp).toBeGreaterThan(0) } // We need to clean up the resources after our test await pool.destroy() @@ -1480,7 +1459,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -1491,7 +1470,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -1507,7 +1486,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -1533,7 +1512,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -1575,6 +1554,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1609,23 +1589,18 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeVirtualTaskRunTime ).toBeGreaterThanOrEqual(0) // We need to clean up the resources after our test @@ -1653,6 +1628,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1687,23 +1663,18 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeVirtualTaskRunTime ).toBeGreaterThanOrEqual(0) // We need to clean up the resources after our test @@ -1736,6 +1707,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -1770,123 +1742,88 @@ describe('Selection strategies test suite', () => { } } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeVirtualTaskRunTime ).toBeGreaterThanOrEqual(0) // We need to clean up the resources after our test await pool.destroy() }) - it('Verify WEIGHTED_ROUND_ROBIN strategy internals are resets after setting it', async () => { + it("Verify WEIGHTED_ROUND_ROBIN strategy internals aren't reset after setting it", async () => { const workerChoiceStrategy = WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN let pool = new FixedThreadPool( max, - './tests/worker-files/thread/testWorker.mjs' + './tests/worker-files/thread/testWorker.mjs', + { workerChoiceStrategy } ) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).nextWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).previousWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).defaultWorkerWeight - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).workerNodeVirtualTaskRunTime - ).toBeDefined() + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).nextWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).previousWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).workerNodeVirtualTaskRunTime = randomInt(100, 1000) pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeVirtualTaskRunTime - ).toBe(0) + ).toBeGreaterThan(99) await pool.destroy() pool = new DynamicThreadPool( min, max, - './tests/worker-files/thread/testWorker.mjs' + './tests/worker-files/thread/testWorker.mjs', + { workerChoiceStrategy } ) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).nextWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).previousWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).defaultWorkerWeight - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).workerNodeVirtualTaskRunTime - ).toBeDefined() + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).nextWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).previousWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).workerNodeVirtualTaskRunTime = randomInt(100, 1000) pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeVirtualTaskRunTime - ).toBe(0) + ).toBeGreaterThan(99) // We need to clean up the resources after our test await pool.destroy() }) @@ -1899,7 +1836,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -1910,7 +1847,7 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy } ) - expect(pool.workerChoiceStrategyContext.getStrategyPolicy()).toStrictEqual({ + expect(pool.workerChoiceStrategiesContext.getPolicy()).toStrictEqual({ dynamicWorkerUsage: false, dynamicWorkerReady: true }) @@ -1927,7 +1864,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -1953,7 +1890,7 @@ describe('Selection strategies test suite', () => { { workerChoiceStrategy } ) expect( - pool.workerChoiceStrategyContext.getTaskStatisticsRequirements() + pool.workerChoiceStrategiesContext.getTaskStatisticsRequirements() ).toStrictEqual({ runTime: { aggregate: true, @@ -1998,6 +1935,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -2022,39 +1960,37 @@ describe('Selection strategies test suite', () => { ) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).roundId ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeId ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toEqual(expect.any(Number)) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).roundWeights - ).toStrictEqual([ - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ]) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights.length + ).toBe(1) + expect( + Number.isSafeInteger( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights[0] + ) + ).toBe(true) // We need to clean up the resources after our test await pool.destroy() }) @@ -2083,6 +2019,7 @@ describe('Selection strategies test suite', () => { executing: 0, queued: 0, maxQueued: 0, + sequentiallyStolen: 0, stolen: 0, failed: 0 }, @@ -2107,186 +2044,152 @@ describe('Selection strategies test suite', () => { ) } expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ).toBeGreaterThan(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).roundId ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeId ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey ).toBe(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toEqual(expect.any(Number)) + ).toEqual(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).roundWeights - ).toStrictEqual([ - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ]) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights.length + ).toBe(1) + expect( + Number.isSafeInteger( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights[0] + ) + ).toBe(true) // We need to clean up the resources after our test await pool.destroy() }) - it('Verify INTERLEAVED_WEIGHTED_ROUND_ROBIN strategy internals are resets after setting it', async () => { + it("Verify INTERLEAVED_WEIGHTED_ROUND_ROBIN strategy internals aren't resets after setting it", async () => { const workerChoiceStrategy = WorkerChoiceStrategies.INTERLEAVED_WEIGHTED_ROUND_ROBIN let pool = new FixedThreadPool( max, - './tests/worker-files/thread/testWorker.mjs' + './tests/worker-files/thread/testWorker.mjs', + { workerChoiceStrategy } ) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).roundId - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).workerNodeId - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).nextWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).previousWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).defaultWorkerWeight - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).roundWeights - ).toBeDefined() + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).roundId = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).workerNodeId = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).nextWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).previousWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).roundWeights = [randomInt(1, max - 1), randomInt(1, max - 1)] pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).roundId - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeId - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).roundWeights - ).toStrictEqual([ - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ]) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights.length + ).toBeGreaterThan(1) + expect( + Number.isSafeInteger( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights[0] + ) + ).toBe(true) await pool.destroy() pool = new DynamicThreadPool( min, max, - './tests/worker-files/thread/testWorker.mjs' + './tests/worker-files/thread/testWorker.mjs', + { workerChoiceStrategy } ) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).roundId - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).workerNodeId - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).nextWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).previousWorkerNodeKey - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).defaultWorkerWeight - ).toBeDefined() - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - workerChoiceStrategy - ).roundWeights - ).toBeDefined() + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).roundId = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).workerNodeId = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).nextWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).previousWorkerNodeKey = randomInt(1, max - 1) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + workerChoiceStrategy + ).roundWeights = [randomInt(1, max - 1), randomInt(1, max - 1)] pool.setWorkerChoiceStrategy(workerChoiceStrategy) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).roundId - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).workerNodeId - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).nextWorkerNodeKey - ).toBe(0) + ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy ).previousWorkerNodeKey - ).toBe(0) - expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight ).toBeGreaterThan(0) expect( - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).roundWeights - ).toStrictEqual([ - pool.workerChoiceStrategyContext.workerChoiceStrategies.get( - pool.workerChoiceStrategyContext.workerChoiceStrategy - ).defaultWorkerWeight - ]) + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights.length + ).toBeGreaterThan(1) + expect( + Number.isSafeInteger( + pool.workerChoiceStrategiesContext.workerChoiceStrategies.get( + pool.workerChoiceStrategiesContext.defaultWorkerChoiceStrategy + ).roundWeights[0] + ) + ).toBe(true) // We need to clean up the resources after our test await pool.destroy() }) @@ -2300,6 +2203,6 @@ describe('Selection strategies test suite', () => { './tests/worker-files/thread/testWorker.mjs', { workerChoiceStrategy: 'UNKNOWN_STRATEGY' } ) - ).toThrowError("Invalid worker choice strategy 'UNKNOWN_STRATEGY'") + ).toThrow("Invalid worker choice strategy 'UNKNOWN_STRATEGY'") }) })