build(deps): bump poolifier

[poolifier.git] / benchmarks / internal / bench.mjs

import {
  PoolTypes,
  WorkerTypes,
  availableParallelism
} from '../../lib/index.mjs'
import { TaskFunctions } from '../benchmarks-types.js'
import {
  buildPoolifierPool,
  runPoolifierPoolBenchmark
} from '../benchmarks-utils.js'

const poolSize = availableParallelism()
const taskExecutions = 1
const workerData = {
  function: TaskFunctions.jsonIntegerSerialization,
  taskSize: 1000
}

// FixedThreadPool
await runPoolifierPoolBenchmark(
  'Poolifier FixedThreadPool',
  buildPoolifierPool(WorkerTypes.thread, PoolTypes.fixed, poolSize),
  {
    taskExecutions,
    workerData
  }
)

// DynamicThreadPool
await runPoolifierPoolBenchmark(
  'Poolifier DynamicThreadPool',
  buildPoolifierPool(WorkerTypes.thread, PoolTypes.dynamic, poolSize),
  {
    taskExecutions,
    workerData
  }
)

// FixedClusterPool
await runPoolifierPoolBenchmark(
  'Poolifier FixedClusterPool',
  buildPoolifierPool(WorkerTypes.cluster, PoolTypes.fixed, poolSize),
  {
    taskExecutions,
    workerData
  }
)

// DynamicClusterPool
await runPoolifierPoolBenchmark(
  'Poolifier DynamicClusterPool',
  buildPoolifierPool(WorkerTypes.cluster, PoolTypes.dynamic, poolSize),
  {
    taskExecutions,
    workerData
  }
)