availableParallelism
} from '../../lib/index.mjs'
import { TaskFunctions } from '../benchmarks-types.js'
-import {
- buildPoolifierPool,
- runPoolifierPoolBenchmark
-} from '../benchmarks-utils.js'
+import { runPoolifierPoolBenchmark } from '../benchmarks-utils.js'
const poolSize = availableParallelism()
const taskExecutions = 1
// FixedThreadPool
await runPoolifierPoolBenchmark(
- 'Poolifier FixedThreadPool',
- buildPoolifierPool(WorkerTypes.thread, PoolTypes.fixed, poolSize),
+ 'FixedThreadPool',
+ WorkerTypes.thread,
+ PoolTypes.fixed,
+ poolSize,
{
taskExecutions,
workerData
// DynamicThreadPool
await runPoolifierPoolBenchmark(
- 'Poolifier DynamicThreadPool',
- buildPoolifierPool(WorkerTypes.thread, PoolTypes.dynamic, poolSize),
+ 'DynamicThreadPool',
+ WorkerTypes.thread,
+ PoolTypes.dynamic,
+ poolSize,
{
taskExecutions,
workerData
// FixedClusterPool
await runPoolifierPoolBenchmark(
- 'Poolifier FixedClusterPool',
- buildPoolifierPool(WorkerTypes.cluster, PoolTypes.fixed, poolSize),
+ 'FixedClusterPool',
+ WorkerTypes.cluster,
+ PoolTypes.fixed,
+ poolSize,
{
taskExecutions,
workerData
// DynamicClusterPool
await runPoolifierPoolBenchmark(
- 'Poolifier DynamicClusterPool',
- buildPoolifierPool(WorkerTypes.cluster, PoolTypes.dynamic, poolSize),
+ 'DynamicClusterPool',
+ WorkerTypes.cluster,
+ PoolTypes.dynamic,
+ poolSize,
{
taskExecutions,
workerData