availableParallelism
} from '../../lib/index.mjs'
import { TaskFunctions } from '../benchmarks-types.mjs'
-import { buildPool, runTest } from '../benchmarks-utils.mjs'
+import { buildPoolifierPool, runPoolifierTest } from '../benchmarks-utils.mjs'
const poolSize = availableParallelism()
const pools = []
for (const measurement of [Measurements.runTime, Measurements.elu]) {
pools.push([
`${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}|measurement:${measurement}`,
- buildPool(workerType, poolType, poolSize, {
+ buildPoolifierPool(workerType, poolType, poolSize, {
workerChoiceStrategy,
workerChoiceStrategyOptions: {
measurement
} else {
pools.push([
`${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}`,
- buildPool(workerType, poolType, poolSize, {
+ buildPoolifierPool(workerType, poolType, poolSize, {
workerChoiceStrategy,
enableTasksQueue
})
const addPools = pools =>
pools.map(([name, pool]) => {
return add(name, async () => {
- await runTest(pool, {
+ await runPoolifierTest(pool, {
taskExecutions,
workerData
})