import {
LIST_FORMATTER,
buildPoolifierPool,
+ getPoolImplementationName,
runPoolifierTest
} from '../benchmarks-utils.mjs'
const taskExecutions = 1
const workerData = {
function: TaskFunctions.jsonIntegerSerialization,
- taskSize: 100
+ taskSize: 1000
}
const poolifierSuite = new Benchmark.Suite('Poolifier')
for (const workerChoiceStrategy of Object.values(WorkerChoiceStrategies)) {
for (const enableTasksQueue of [false, true]) {
poolifierSuite.add(
- `${pool.constructor.name}|${workerChoiceStrategy}|${
+ `${getPoolImplementationName(pool)}|${workerChoiceStrategy}|${
enableTasksQueue ? 'with' : 'without'
} tasks queue`,
async () => {
.on('cycle', event => {
console.info(event.target.toString())
})
- .on('complete', function () {
+ .on('complete', async function () {
console.info(
'Fastest is ' + LIST_FORMATTER.format(this.filter('fastest').map('name'))
)
- fixedThreadPool.destroy()
+ await fixedThreadPool.destroy()
})
.run({ async: true })