X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=benchmarks%2Finternal%2Fbench.mjs;h=8235d5727b9e0043c0948fd4dfbbb8249a57e05c;hb=1adc6af72c087b9412e625bc9576be67d40e7397;hp=1fbcc5aa89b0aaf875c62818812cfc0767969f4e;hpb=149fdbb9ad4a54f2a96409f2fe68b73c66149729;p=poolifier.git diff --git a/benchmarks/internal/bench.mjs b/benchmarks/internal/bench.mjs index 1fbcc5aa..8235d572 100644 --- a/benchmarks/internal/bench.mjs +++ b/benchmarks/internal/bench.mjs @@ -1,50 +1,55 @@ import { add, complete, cycle, save, suite } from 'benny' import { + Measurements, + PoolTypes, WorkerChoiceStrategies, + WorkerTypes, availableParallelism } from '../../lib/index.mjs' -import { - PoolTypes, - WorkerFunctions, - WorkerTypes -} from '../benchmarks-types.mjs' +import { WorkerFunctions } from '../benchmarks-types.mjs' import { buildPool, runTest } from '../benchmarks-utils.mjs' const poolSize = availableParallelism() const pools = [] for (const poolType of Object.values(PoolTypes)) { for (const workerType of Object.values(WorkerTypes)) { + if (workerType === WorkerTypes.cluster) { + continue + } for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) { - for (const tasksQueue of [false, true]) { - const pool = buildPool( - workerType, - poolType, - poolSize, - tasksQueue - ? { - ...{ - workerChoiceStrategy + for (const enableTasksQueue of [false, true]) { + if (workerChoiceStrategy === WorkerChoiceStrategies.FAIR_SHARE) { + for (const measurement of [Measurements.runTime, Measurements.elu]) { + pools.push([ + `${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}|measurement:${measurement}`, + buildPool(workerType, poolType, poolSize, { + workerChoiceStrategy, + workerChoiceStrategyOptions: { + measurement }, - ...{ enableTasksQueue: true } - } - : { - workerChoiceStrategy - } - ) - pools.push([ - `${poolType}:${workerType}:${workerChoiceStrategy}:${tasksQueue}`, - pool - ]) + enableTasksQueue + }) + ]) + } + } else { + pools.push([ + `${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}`, + buildPool(workerType, poolType, poolSize, { + workerChoiceStrategy, + enableTasksQueue + }) + ]) + } } } } } + const taskExecutions = 1 const workerData = { function: WorkerFunctions.jsonIntegerSerialization, taskSize: 1000 } - const addPools = pools => pools.map(([name, pool]) => { return add(name, async () => { @@ -57,7 +62,6 @@ const addPools = pools => const resultsFile = 'poolifier' const resultsFolder = 'benchmarks/internal/results' - suite( 'Poolifier', ...addPools(pools),