X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=benchmarks%2Fbenchmarks-utils.mjs;h=5db55b3b11c9b8c956e46397674e71a34471d241;hb=5b95eb9bcafda56ce57003da834cf4e153bb0509;hp=a74a36ee6dbb05ad645aea2f468c2b61835efdfb;hpb=47ab5d238b0f0bcc72b99959108ca53a9935dd22;p=poolifier.git diff --git a/benchmarks/benchmarks-utils.mjs b/benchmarks/benchmarks-utils.mjs index a74a36ee..5db55b3b 100644 --- a/benchmarks/benchmarks-utils.mjs +++ b/benchmarks/benchmarks-utils.mjs @@ -76,6 +76,77 @@ const runPoolifierPool = async (pool, { taskExecutions, workerData }) => { } export const runPoolifierBenchmarkBenchmarkJs = async ( + name, + workerType, + poolType, + poolSize, + poolOptions, + { taskExecutions, workerData } +) => { + return await new Promise((resolve, reject) => { + const pool = buildPoolifierPool(workerType, poolType, poolSize, poolOptions) + let workerChoiceStrategy + let enableTasksQueue + let workerChoiceStrategyOptions + if (poolOptions != null) { + ({ + workerChoiceStrategy, + enableTasksQueue, + workerChoiceStrategyOptions + } = poolOptions) + } + const measurement = workerChoiceStrategyOptions?.measurement + new Benchmark( + `${name} with ${workerChoiceStrategy ?? pool.opts.workerChoiceStrategy}${ + measurement != null ? `, with ${measurement}` : '' + } and ${enableTasksQueue ? 'with' : 'without'} tasks queue`, + async () => { + await runPoolifierPool(pool, { + taskExecutions, + workerData + }) + }, + { + onStart: () => { + if (workerChoiceStrategy != null) { + strictEqual(pool.opts.workerChoiceStrategy, workerChoiceStrategy) + } + if (enableTasksQueue != null) { + strictEqual(pool.opts.enableTasksQueue, enableTasksQueue) + } + if (measurement != null) { + strictEqual( + pool.opts.workerChoiceStrategyOptions.measurement, + measurement + ) + } + }, + onComplete: event => { + console.info(event.target.toString()) + if (pool.started && !pool.destroying) { + pool.destroy().then(resolve).catch(reject) + } else { + resolve() + } + }, + onError: event => { + if (pool.started && !pool.destroying) { + pool + .destroy() + .then(() => { + return reject(event.target.error) + }) + .catch(() => {}) + } else { + reject(event.target.error) + } + } + } + ).run({ async: true }) + }) +} + +export const runPoolifierBenchmarkBenchmarkJsSuite = async ( name, workerType, poolType, @@ -113,7 +184,7 @@ export const runPoolifierBenchmarkBenchmarkJs = async ( if (workerChoiceStrategy === WorkerChoiceStrategies.FAIR_SHARE) { for (const measurement of [Measurements.runTime, Measurements.elu]) { suite.add( - `${name} with ${workerChoiceStrategy}, with measurement ${measurement} and ${ + `${name} with ${workerChoiceStrategy}, with ${measurement} and ${ enableTasksQueue ? 'with' : 'without' } tasks queue`, async () => {