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))