WorkerTypes,
availableParallelism
} from '../../lib/index.mjs'
-import { WorkerFunctions } from '../benchmarks-types.mjs'
+import { TaskFunctions } from '../benchmarks-types.mjs'
import { buildPool, runTest } from '../benchmarks-utils.mjs'
const poolSize = availableParallelism()
for (const enableTasksQueue of [false, true]) {
if (workerChoiceStrategy === WorkerChoiceStrategies.FAIR_SHARE) {
for (const measurement of [Measurements.runTime, Measurements.elu]) {
- const pool = buildPool(workerType, poolType, poolSize, {
- workerChoiceStrategy,
- workerChoiceStrategyOptions: {
- measurement
- },
- enableTasksQueue
- })
pools.push([
`${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}|measurement:${measurement}`,
- pool
+ buildPool(workerType, poolType, poolSize, {
+ workerChoiceStrategy,
+ workerChoiceStrategyOptions: {
+ measurement
+ },
+ enableTasksQueue
+ })
])
}
} else {
- const pool = buildPool(workerType, poolType, poolSize, {
- workerChoiceStrategy,
- enableTasksQueue
- })
pools.push([
`${poolType}|${workerType}|${workerChoiceStrategy}|tasks queue:${enableTasksQueue}`,
- pool
+ buildPool(workerType, poolType, poolSize, {
+ workerChoiceStrategy,
+ enableTasksQueue
+ })
])
}
}
const taskExecutions = 1
const workerData = {
- function: WorkerFunctions.jsonIntegerSerialization,
+ function: TaskFunctions.jsonIntegerSerialization,
taskSize: 1000
}
-const addPools = pools =>
+const addPools = (pools) =>
pools.map(([name, pool]) => {
return add(name, async () => {
await runTest(pool, {
// eslint-disable-next-line n/no-process-exit
return process.exit()
})
- .catch(err => console.error(err))
+ .catch((err) => console.error(err))