1 import { add, complete, cycle, save, suite } from 'benny'
3 WorkerChoiceStrategies,
5 } from '../../lib/index.mjs'
10 } from '../benchmarks-types.mjs'
11 import { buildPool, runTest } from '../benchmarks-utils.mjs'
13 const WorkerTypes = Object.freeze({
17 const poolSize = availableParallelism()
19 for (const poolType of Object.values(PoolTypes)) {
20 for (const workerType of Object.values(WorkerTypes)) {
21 for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) {
22 for (const tasksQueue of [false, true]) {
23 const pool = buildPool(
32 ...{ enableTasksQueue: true }
39 `${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${tasksQueue}`,
47 const taskExecutions = 1
49 function: WorkerFunctions.jsonIntegerSerialization,
52 const addPools = pools =>
53 pools.map(([name, pool]) => {
54 return add(name, async () => {
62 const resultsFile = 'poolifier'
63 const resultsFolder = 'benchmarks/internal/results'
71 folder: resultsFolder,
77 folder: resultsFolder,
83 folder: resultsFolder,
89 // eslint-disable-next-line n/no-process-exit
92 .catch(err => console.error(err))