perf: add measurement coverage to benchmark
[poolifier.git] / benchmarks / internal / bench.mjs
1 import { add, complete, cycle, save, suite } from 'benny'
2 import {
3 Measurements,
4 PoolTypes,
5 WorkerChoiceStrategies,
6 WorkerTypes,
7 availableParallelism
8 } from '../../lib/index.mjs'
9 import { WorkerFunctions } from '../benchmarks-types.mjs'
10 import { buildPool, runTest } from '../benchmarks-utils.mjs'
11
12 const poolSize = availableParallelism()
13 const pools = []
14 for (const poolType of Object.values(PoolTypes)) {
15 for (const workerType of Object.values(WorkerTypes)) {
16 if (workerType === WorkerTypes.cluster) {
17 continue
18 }
19 for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) {
20 for (const enableTasksQueue of [false, true]) {
21 if (workerChoiceStrategy === WorkerChoiceStrategies.FAIR_SHARE) {
22 for (const measurement of [Measurements.runTime, Measurements.elu]) {
23 const pool = buildPool(workerType, poolType, poolSize, {
24 workerChoiceStrategy,
25 workerChoiceStrategyOptions: {
26 measurement
27 },
28 enableTasksQueue
29 })
30 pools.push([
31 `${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}|measurement:${measurement}`,
32 pool
33 ])
34 }
35 } else {
36 const pool = buildPool(workerType, poolType, poolSize, {
37 workerChoiceStrategy,
38 enableTasksQueue
39 })
40 pools.push([
41 `${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}`,
42 pool
43 ])
44 }
45 }
46 }
47 }
48 }
49
50 const taskExecutions = 1
51 const workerData = {
52 function: WorkerFunctions.jsonIntegerSerialization,
53 taskSize: 1000
54 }
55 const addPools = pools =>
56 pools.map(([name, pool]) => {
57 return add(name, async () => {
58 await runTest(pool, {
59 taskExecutions,
60 workerData
61 })
62 })
63 })
64
65 const resultsFile = 'poolifier'
66 const resultsFolder = 'benchmarks/internal/results'
67 suite(
68 'Poolifier',
69 ...addPools(pools),
70 cycle(),
71 complete(),
72 save({
73 file: resultsFile,
74 folder: resultsFolder,
75 format: 'json',
76 details: true
77 }),
78 save({
79 file: resultsFile,
80 folder: resultsFolder,
81 format: 'chart.html',
82 details: true
83 }),
84 save({
85 file: resultsFile,
86 folder: resultsFolder,
87 format: 'table.html',
88 details: true
89 })
90 )
91 .then(() => {
92 // eslint-disable-next-line n/no-process-exit
93 return process.exit()
94 })
95 .catch(err => console.error(err))