X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=tests%2Fpools%2Fabstract-pool.test.mjs;h=ec481d2ca918c33f42da25c17c9acc22806594ac;hb=3a5027122ca6401ae1d755843b20f714c61e3240;hp=ec8fe516ffbd278d162306920d182be9e76c8427;hpb=937d524da3a5cce4795b85ddd1c430f0d184f731;p=poolifier.git diff --git a/tests/pools/abstract-pool.test.mjs b/tests/pools/abstract-pool.test.mjs index ec8fe516..ec481d2c 100644 --- a/tests/pools/abstract-pool.test.mjs +++ b/tests/pools/abstract-pool.test.mjs @@ -17,7 +17,7 @@ import { PoolEvents, PoolTypes, WorkerChoiceStrategies, - WorkerTypes + WorkerTypes, } from '../../lib/index.cjs' import { WorkerNode } from '../../lib/pools/worker-node.cjs' import { defaultBucketSize, PriorityQueue } from '../../lib/priority-queue.cjs' @@ -58,7 +58,7 @@ describe('Abstract pool test suite', () => { numberOfWorkers, './tests/worker-files/thread/testWorker.mjs', { - errorHandler: e => console.error(e) + errorHandler: e => console.error(e), } ) ).toThrow( @@ -230,7 +230,7 @@ describe('Abstract pool test suite', () => { enableEvents: true, restartWorkerOnError: true, enableTasksQueue: false, - workerChoiceStrategy: WorkerChoiceStrategies.ROUND_ROBIN + workerChoiceStrategy: WorkerChoiceStrategies.ROUND_ROBIN, }) for (const [, workerChoiceStrategy] of pool.workerChoiceStrategiesContext .workerChoiceStrategies) { @@ -240,8 +240,8 @@ describe('Abstract pool test suite', () => { elu: { median: false }, weights: expect.objectContaining({ 0: expect.any(Number), - [pool.info.maxSize - 1]: expect.any(Number) - }) + [pool.info.maxSize - 1]: expect.any(Number), + }), }) } await pool.destroy() @@ -253,7 +253,7 @@ describe('Abstract pool test suite', () => { workerChoiceStrategy: WorkerChoiceStrategies.LEAST_USED, workerChoiceStrategyOptions: { runTime: { median: true }, - weights: { 0: 300, 1: 200 } + weights: { 0: 300, 1: 200 }, }, enableEvents: false, restartWorkerOnError: false, @@ -262,7 +262,7 @@ describe('Abstract pool test suite', () => { messageHandler: testHandler, errorHandler: testHandler, onlineHandler: testHandler, - exitHandler: testHandler + exitHandler: testHandler, } ) expect(pool.emitter).toBeUndefined() @@ -276,17 +276,17 @@ describe('Abstract pool test suite', () => { size: Math.pow(numberOfWorkers, 2), taskStealing: true, tasksStealingOnBackPressure: false, - tasksFinishedTimeout: 2000 + tasksFinishedTimeout: 2000, }, workerChoiceStrategy: WorkerChoiceStrategies.LEAST_USED, workerChoiceStrategyOptions: { runTime: { median: true }, - weights: { 0: 300, 1: 200 } + weights: { 0: 300, 1: 200 }, }, onlineHandler: testHandler, messageHandler: testHandler, errorHandler: testHandler, - exitHandler: testHandler + exitHandler: testHandler, }) for (const [, workerChoiceStrategy] of pool.workerChoiceStrategiesContext .workerChoiceStrategies) { @@ -294,7 +294,7 @@ describe('Abstract pool test suite', () => { runTime: { median: true }, waitTime: { median: false }, elu: { median: false }, - weights: { 0: 300, 1: 200 } + weights: { 0: 300, 1: 200 }, }) } await pool.destroy() @@ -307,7 +307,7 @@ describe('Abstract pool test suite', () => { numberOfWorkers, './tests/worker-files/thread/testWorker.mjs', { - workerChoiceStrategy: 'invalidStrategy' + workerChoiceStrategy: 'invalidStrategy', } ) ).toThrow(new Error("Invalid worker choice strategy 'invalidStrategy'")) @@ -317,7 +317,7 @@ describe('Abstract pool test suite', () => { numberOfWorkers, './tests/worker-files/thread/testWorker.mjs', { - workerChoiceStrategyOptions: { weights: {} } + workerChoiceStrategyOptions: { weights: {} }, } ) ).toThrow( @@ -331,7 +331,7 @@ describe('Abstract pool test suite', () => { numberOfWorkers, './tests/worker-files/thread/testWorker.mjs', { - workerChoiceStrategyOptions: { measurement: 'invalidMeasurement' } + workerChoiceStrategyOptions: { measurement: 'invalidMeasurement' }, } ) ).toThrow( @@ -346,7 +346,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: 'invalidTasksQueueOptions' + tasksQueueOptions: 'invalidTasksQueueOptions', } ) ).toThrow( @@ -359,7 +359,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { concurrency: 0 } + tasksQueueOptions: { concurrency: 0 }, } ) ).toThrow( @@ -374,7 +374,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { concurrency: -1 } + tasksQueueOptions: { concurrency: -1 }, } ) ).toThrow( @@ -389,7 +389,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { concurrency: 0.2 } + tasksQueueOptions: { concurrency: 0.2 }, } ) ).toThrow( @@ -402,7 +402,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { size: 0 } + tasksQueueOptions: { size: 0 }, } ) ).toThrow( @@ -417,7 +417,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { size: -1 } + tasksQueueOptions: { size: -1 }, } ) ).toThrow( @@ -432,7 +432,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { size: 0.2 } + tasksQueueOptions: { size: 0.2 }, } ) ).toThrow( @@ -455,8 +455,8 @@ describe('Abstract pool test suite', () => { elu: { median: false }, weights: expect.objectContaining({ 0: expect.any(Number), - [pool.info.maxSize - 1]: expect.any(Number) - }) + [pool.info.maxSize - 1]: expect.any(Number), + }), }) } expect( @@ -465,26 +465,26 @@ describe('Abstract pool test suite', () => { runTime: { aggregate: true, average: true, - median: false + median: false, }, waitTime: { aggregate: true, average: true, - median: false + median: false, }, elu: { aggregate: true, average: true, - median: false - } + median: false, + }, }) pool.setWorkerChoiceStrategyOptions({ runTime: { median: true }, - elu: { median: true } + elu: { median: true }, }) expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({ runTime: { median: true }, - elu: { median: true } + elu: { median: true }, }) for (const [, workerChoiceStrategy] of pool.workerChoiceStrategiesContext .workerChoiceStrategies) { @@ -494,8 +494,8 @@ describe('Abstract pool test suite', () => { elu: { median: true }, weights: expect.objectContaining({ 0: expect.any(Number), - [pool.info.maxSize - 1]: expect.any(Number) - }) + [pool.info.maxSize - 1]: expect.any(Number), + }), }) } expect( @@ -504,26 +504,26 @@ describe('Abstract pool test suite', () => { runTime: { aggregate: true, average: false, - median: true + median: true, }, waitTime: { aggregate: true, average: true, - median: false + median: false, }, elu: { aggregate: true, average: false, - median: true - } + median: true, + }, }) pool.setWorkerChoiceStrategyOptions({ runTime: { median: false }, - elu: { median: false } + elu: { median: false }, }) expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({ runTime: { median: false }, - elu: { median: false } + elu: { median: false }, }) for (const [, workerChoiceStrategy] of pool.workerChoiceStrategiesContext .workerChoiceStrategies) { @@ -533,8 +533,8 @@ describe('Abstract pool test suite', () => { elu: { median: false }, weights: expect.objectContaining({ 0: expect.any(Number), - [pool.info.maxSize - 1]: expect.any(Number) - }) + [pool.info.maxSize - 1]: expect.any(Number), + }), }) } expect( @@ -543,18 +543,18 @@ describe('Abstract pool test suite', () => { runTime: { aggregate: true, average: true, - median: false + median: false, }, waitTime: { aggregate: true, average: true, - median: false + median: false, }, elu: { aggregate: true, average: true, - median: false - } + median: false, + }, }) expect(() => pool.setWorkerChoiceStrategyOptions('invalidWorkerChoiceStrategyOptions') @@ -592,7 +592,7 @@ describe('Abstract pool test suite', () => { size: Math.pow(numberOfWorkers, 2), taskStealing: true, tasksStealingOnBackPressure: false, - tasksFinishedTimeout: 2000 + tasksFinishedTimeout: 2000, }) pool.enableTasksQueue(true, { concurrency: 2 }) expect(pool.opts.enableTasksQueue).toBe(true) @@ -601,7 +601,7 @@ describe('Abstract pool test suite', () => { size: Math.pow(numberOfWorkers, 2), taskStealing: true, tasksStealingOnBackPressure: false, - tasksFinishedTimeout: 2000 + tasksFinishedTimeout: 2000, }) pool.enableTasksQueue(false) expect(pool.opts.enableTasksQueue).toBe(false) @@ -620,7 +620,7 @@ describe('Abstract pool test suite', () => { size: Math.pow(numberOfWorkers, 2), taskStealing: true, tasksStealingOnBackPressure: false, - tasksFinishedTimeout: 2000 + tasksFinishedTimeout: 2000, }) for (const workerNode of pool.workerNodes) { expect(workerNode.tasksQueueBackPressureSize).toBe( @@ -632,14 +632,14 @@ describe('Abstract pool test suite', () => { size: 2, taskStealing: false, tasksStealingOnBackPressure: false, - tasksFinishedTimeout: 3000 + tasksFinishedTimeout: 3000, }) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 2, size: 2, taskStealing: false, tasksStealingOnBackPressure: false, - tasksFinishedTimeout: 3000 + tasksFinishedTimeout: 3000, }) for (const workerNode of pool.workerNodes) { expect(workerNode.tasksQueueBackPressureSize).toBe( @@ -649,14 +649,14 @@ describe('Abstract pool test suite', () => { pool.setTasksQueueOptions({ concurrency: 1, taskStealing: true, - tasksStealingOnBackPressure: true + tasksStealingOnBackPressure: true, }) expect(pool.opts.tasksQueueOptions).toStrictEqual({ concurrency: 1, size: Math.pow(numberOfWorkers, 2), taskStealing: true, tasksStealingOnBackPressure: true, - tasksFinishedTimeout: 2000 + tasksFinishedTimeout: 2000, }) for (const workerNode of pool.workerNodes) { expect(workerNode.tasksQueueBackPressureSize).toBe( @@ -715,7 +715,7 @@ describe('Abstract pool test suite', () => { busyWorkerNodes: 0, executedTasks: 0, executingTasks: 0, - failedTasks: 0 + failedTasks: 0, }) await pool.destroy() pool = new DynamicClusterPool( @@ -738,7 +738,7 @@ describe('Abstract pool test suite', () => { busyWorkerNodes: 0, executedTasks: 0, executingTasks: 0, - failedTasks: 0 + failedTasks: 0, }) await pool.destroy() }) @@ -758,22 +758,22 @@ describe('Abstract pool test suite', () => { maxQueued: 0, sequentiallyStolen: 0, stolen: 0, - failed: 0 + failed: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) } await pool.destroy() @@ -822,7 +822,7 @@ describe('Abstract pool test suite', () => { dynamic: false, ready: true, stealing: false, - backPressure: false + backPressure: false, }) } await pool.destroy() @@ -839,7 +839,7 @@ describe('Abstract pool test suite', () => { dynamic: false, ready: true, stealing: false, - backPressure: false + backPressure: false, }) } await pool.destroy() @@ -868,7 +868,7 @@ describe('Abstract pool test suite', () => { numberOfWorkers, './tests/worker-files/cluster/testWorker.cjs', { - startWorkers: false + startWorkers: false, } ) expect(pool.info.started).toBe(false) @@ -932,22 +932,22 @@ describe('Abstract pool test suite', () => { maxQueued: 0, sequentiallyStolen: 0, stolen: 0, - failed: 0 + failed: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) } await Promise.all(promises) @@ -960,22 +960,22 @@ describe('Abstract pool test suite', () => { maxQueued: 0, sequentiallyStolen: 0, stolen: 0, - failed: 0 + failed: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) } await pool.destroy() @@ -1002,22 +1002,22 @@ describe('Abstract pool test suite', () => { maxQueued: 0, sequentiallyStolen: 0, stolen: 0, - failed: 0 + failed: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) expect(workerNode.usage.tasks.executed).toBeGreaterThan(0) expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual( @@ -1034,22 +1034,22 @@ describe('Abstract pool test suite', () => { maxQueued: 0, sequentiallyStolen: 0, stolen: 0, - failed: 0 + failed: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) expect(workerNode.usage.tasks.executed).toBeGreaterThan(0) expect(workerNode.usage.tasks.executed).toBeLessThanOrEqual( @@ -1090,7 +1090,7 @@ describe('Abstract pool test suite', () => { busyWorkerNodes: expect.any(Number), executedTasks: expect.any(Number), executingTasks: expect.any(Number), - failedTasks: expect.any(Number) + failedTasks: expect.any(Number), }) await pool.destroy() }) @@ -1131,7 +1131,7 @@ describe('Abstract pool test suite', () => { busyWorkerNodes: expect.any(Number), executedTasks: expect.any(Number), executingTasks: expect.any(Number), - failedTasks: expect.any(Number) + failedTasks: expect.any(Number), }) await pool.destroy() }) @@ -1171,7 +1171,7 @@ describe('Abstract pool test suite', () => { busyWorkerNodes: expect.any(Number), executedTasks: expect.any(Number), executingTasks: expect.any(Number), - failedTasks: expect.any(Number) + failedTasks: expect.any(Number), }) await pool.destroy() }) @@ -1181,7 +1181,7 @@ describe('Abstract pool test suite', () => { numberOfWorkers, './tests/worker-files/thread/testWorker.mjs', { - enableTasksQueue: true + enableTasksQueue: true, } ) stub(pool, 'hasBackPressure').returns(true) @@ -1219,7 +1219,7 @@ describe('Abstract pool test suite', () => { queuedTasks: expect.any(Number), backPressure: true, stolenTasks: expect.any(Number), - failedTasks: expect.any(Number) + failedTasks: expect.any(Number), }) expect(pool.hasBackPressure.callCount).toBeGreaterThanOrEqual(7) await pool.destroy() @@ -1232,7 +1232,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/asyncWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { tasksFinishedTimeout } + tasksQueueOptions: { tasksFinishedTimeout }, } ) const maxMultiplier = 4 @@ -1261,7 +1261,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/asyncWorker.mjs', { enableTasksQueue: true, - tasksQueueOptions: { tasksFinishedTimeout } + tasksQueueOptions: { tasksFinishedTimeout }, } ) const maxMultiplier = 4 @@ -1303,7 +1303,7 @@ describe('Abstract pool test suite', () => { }, promiseResolve () { if (executionAsyncId() === taskAsyncId) resolveCalls++ - } + }, }) const pool = new FixedThreadPool( numberOfWorkers, @@ -1379,7 +1379,7 @@ describe('Abstract pool test suite', () => { await expect( dynamicThreadPool.addTaskFunction('test', { taskFunction: () => {}, - priority: -21 + priority: -21, }) ).rejects.toThrow( new RangeError("Property 'priority' must be between -20 and 19") @@ -1387,7 +1387,7 @@ describe('Abstract pool test suite', () => { await expect( dynamicThreadPool.addTaskFunction('test', { taskFunction: () => {}, - priority: 20 + priority: 20, }) ).rejects.toThrow( new RangeError("Property 'priority' must be between -20 and 19") @@ -1395,17 +1395,17 @@ describe('Abstract pool test suite', () => { await expect( dynamicThreadPool.addTaskFunction('test', { taskFunction: () => {}, - strategy: 'invalidStrategy' + strategy: 'invalidStrategy', }) ).rejects.toThrow( new Error("Invalid worker choice strategy 'invalidStrategy'") ) expect(dynamicThreadPool.listTaskFunctionsProperties()).toStrictEqual([ { name: DEFAULT_TASK_NAME }, - { name: 'test' } + { name: 'test' }, ]) expect([ - ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys() + ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys(), ]).toStrictEqual([WorkerChoiceStrategies.ROUND_ROBIN]) const echoTaskFunction = data => { return data @@ -1413,24 +1413,24 @@ describe('Abstract pool test suite', () => { await expect( dynamicThreadPool.addTaskFunction('echo', { taskFunction: echoTaskFunction, - strategy: WorkerChoiceStrategies.LEAST_ELU + strategy: WorkerChoiceStrategies.LEAST_ELU, }) ).resolves.toBe(true) expect(dynamicThreadPool.taskFunctions.size).toBe(1) expect(dynamicThreadPool.taskFunctions.get('echo')).toStrictEqual({ taskFunction: echoTaskFunction, - strategy: WorkerChoiceStrategies.LEAST_ELU + strategy: WorkerChoiceStrategies.LEAST_ELU, }) expect([ - ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys() + ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys(), ]).toStrictEqual([ WorkerChoiceStrategies.ROUND_ROBIN, - WorkerChoiceStrategies.LEAST_ELU + WorkerChoiceStrategies.LEAST_ELU, ]) expect(dynamicThreadPool.listTaskFunctionsProperties()).toStrictEqual([ { name: DEFAULT_TASK_NAME }, { name: 'test' }, - { name: 'echo', strategy: WorkerChoiceStrategies.LEAST_ELU } + { name: 'echo', strategy: WorkerChoiceStrategies.LEAST_ELU }, ]) const taskFunctionData = { test: 'test' } const echoResult = await dynamicThreadPool.execute(taskFunctionData, 'echo') @@ -1443,22 +1443,22 @@ describe('Abstract pool test suite', () => { queued: 0, sequentiallyStolen: 0, stolen: 0, - failed: 0 + failed: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: expect.objectContaining({ idle: expect.objectContaining({ - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }), active: expect.objectContaining({ - history: expect.any(CircularBuffer) - }) - }) + history: expect.any(CircularBuffer), + }), + }), }) expect( workerNode.getTaskFunctionWorkerUsage('echo').tasks.executed @@ -1513,7 +1513,7 @@ describe('Abstract pool test suite', () => { await waitPoolEvents(dynamicThreadPool, PoolEvents.ready, 1) expect(dynamicThreadPool.listTaskFunctionsProperties()).toStrictEqual([ { name: DEFAULT_TASK_NAME }, - { name: 'test' } + { name: 'test' }, ]) await expect(dynamicThreadPool.removeTaskFunction('test')).rejects.toThrow( new Error('Cannot remove a task function not handled on the pool side') @@ -1523,23 +1523,23 @@ describe('Abstract pool test suite', () => { } await dynamicThreadPool.addTaskFunction('echo', { taskFunction: echoTaskFunction, - strategy: WorkerChoiceStrategies.LEAST_ELU + strategy: WorkerChoiceStrategies.LEAST_ELU, }) expect(dynamicThreadPool.taskFunctions.size).toBe(1) expect(dynamicThreadPool.taskFunctions.get('echo')).toStrictEqual({ taskFunction: echoTaskFunction, - strategy: WorkerChoiceStrategies.LEAST_ELU + strategy: WorkerChoiceStrategies.LEAST_ELU, }) expect([ - ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys() + ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys(), ]).toStrictEqual([ WorkerChoiceStrategies.ROUND_ROBIN, - WorkerChoiceStrategies.LEAST_ELU + WorkerChoiceStrategies.LEAST_ELU, ]) expect(dynamicThreadPool.listTaskFunctionsProperties()).toStrictEqual([ { name: DEFAULT_TASK_NAME }, { name: 'test' }, - { name: 'echo', strategy: WorkerChoiceStrategies.LEAST_ELU } + { name: 'echo', strategy: WorkerChoiceStrategies.LEAST_ELU }, ]) await expect(dynamicThreadPool.removeTaskFunction('echo')).resolves.toBe( true @@ -1547,11 +1547,11 @@ describe('Abstract pool test suite', () => { expect(dynamicThreadPool.taskFunctions.size).toBe(0) expect(dynamicThreadPool.taskFunctions.get('echo')).toBeUndefined() expect([ - ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys() + ...dynamicThreadPool.workerChoiceStrategiesContext.workerChoiceStrategies.keys(), ]).toStrictEqual([WorkerChoiceStrategies.ROUND_ROBIN]) expect(dynamicThreadPool.listTaskFunctionsProperties()).toStrictEqual([ { name: DEFAULT_TASK_NAME }, - { name: 'test' } + { name: 'test' }, ]) await dynamicThreadPool.destroy() }) @@ -1567,7 +1567,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'jsonIntegerSerialization' }, { name: 'factorial' }, - { name: 'fibonacci' } + { name: 'fibonacci' }, ]) await dynamicThreadPool.destroy() const fixedClusterPool = new FixedClusterPool( @@ -1579,7 +1579,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'jsonIntegerSerialization' }, { name: 'factorial' }, - { name: 'fibonacci' } + { name: 'fibonacci' }, ]) await fixedClusterPool.destroy() }) @@ -1615,7 +1615,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'jsonIntegerSerialization' }, { name: 'factorial' }, - { name: 'fibonacci' } + { name: 'fibonacci' }, ]) await expect( dynamicThreadPool.setDefaultTaskFunction('factorial') @@ -1624,7 +1624,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'factorial' }, { name: 'jsonIntegerSerialization' }, - { name: 'fibonacci' } + { name: 'fibonacci' }, ]) await expect( dynamicThreadPool.setDefaultTaskFunction('fibonacci') @@ -1633,7 +1633,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'fibonacci' }, { name: 'jsonIntegerSerialization' }, - { name: 'factorial' } + { name: 'factorial' }, ]) await dynamicThreadPool.destroy() }) @@ -1660,7 +1660,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'jsonIntegerSerialization' }, { name: 'factorial' }, - { name: 'fibonacci' } + { name: 'fibonacci' }, ]) expect(workerNode.taskFunctionsUsage.size).toBe(3) expect(workerNode.usage.tasks.executed).toBeGreaterThan(0) @@ -1675,22 +1675,22 @@ describe('Abstract pool test suite', () => { failed: 0, queued: 0, sequentiallyStolen: 0, - stolen: 0 + stolen: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) expect( workerNode.getTaskFunctionWorkerUsage(taskFunctionProperties.name) @@ -1730,7 +1730,7 @@ describe('Abstract pool test suite', () => { { name: DEFAULT_TASK_NAME }, { name: 'jsonIntegerSerialization' }, { name: 'factorial' }, - { name: 'fibonacci', priority: -5 } + { name: 'fibonacci', priority: -5 }, ]) expect(workerNode.taskFunctionsUsage.size).toBe(3) expect(workerNode.usage.tasks.executed).toBeGreaterThan(0) @@ -1745,22 +1745,22 @@ describe('Abstract pool test suite', () => { failed: 0, queued: 0, sequentiallyStolen: 0, - stolen: 0 + stolen: 0, }, runTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, waitTime: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, elu: { idle: { - history: expect.any(CircularBuffer) + history: expect.any(CircularBuffer), }, active: { - history: expect.any(CircularBuffer) - } - } + history: expect.any(CircularBuffer), + }, + }, }) expect( workerNode.getTaskFunctionWorkerUsage(taskFunctionProperties.name) @@ -1802,7 +1802,7 @@ describe('Abstract pool test suite', () => { pool.sendTaskFunctionOperationToWorker(workerNodeKey, { taskFunctionOperation: 'add', taskFunctionProperties: { name: 'empty' }, - taskFunction: (() => {}).toString() + taskFunction: (() => {}).toString(), }) ).resolves.toBe(true) expect( @@ -1810,7 +1810,7 @@ describe('Abstract pool test suite', () => { ).toStrictEqual([ { name: DEFAULT_TASK_NAME }, { name: 'test' }, - { name: 'empty' } + { name: 'empty' }, ]) await pool.destroy() }) @@ -1825,14 +1825,14 @@ describe('Abstract pool test suite', () => { pool.sendTaskFunctionOperationToWorkers({ taskFunctionOperation: 'add', taskFunctionProperties: { name: 'empty' }, - taskFunction: (() => {}).toString() + taskFunction: (() => {}).toString(), }) ).resolves.toBe(true) for (const workerNode of pool.workerNodes) { expect(workerNode.info.taskFunctionsProperties).toStrictEqual([ { name: DEFAULT_TASK_NAME }, { name: 'test' }, - { name: 'empty' } + { name: 'empty' }, ]) } await pool.destroy()