repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'master' of github.com:poolifier/poolifier
[poolifier.git]
/
benchmarks
/
internal
/
bench.mjs
diff --git
a/benchmarks/internal/bench.mjs
b/benchmarks/internal/bench.mjs
index 8235d5727b9e0043c0948fd4dfbbb8249a57e05c..193827f3a24da416f58e079dd8cd546c8b50d8cd 100644
(file)
--- a/
benchmarks/internal/bench.mjs
+++ b/
benchmarks/internal/bench.mjs
@@
-6,7
+6,7
@@
import {
WorkerTypes,
availableParallelism
} from '../../lib/index.mjs'
WorkerTypes,
availableParallelism
} from '../../lib/index.mjs'
-import {
Worker
Functions } from '../benchmarks-types.mjs'
+import {
Task
Functions } from '../benchmarks-types.mjs'
import { buildPool, runTest } from '../benchmarks-utils.mjs'
const poolSize = availableParallelism()
import { buildPool, runTest } from '../benchmarks-utils.mjs'
const poolSize = availableParallelism()
@@
-47,10
+47,10
@@
for (const poolType of Object.values(PoolTypes)) {
const taskExecutions = 1
const workerData = {
const taskExecutions = 1
const workerData = {
- function:
Worker
Functions.jsonIntegerSerialization,
+ function:
Task
Functions.jsonIntegerSerialization,
taskSize: 1000
}
taskSize: 1000
}
-const addPools =
pools
=>
+const addPools =
(pools)
=>
pools.map(([name, pool]) => {
return add(name, async () => {
await runTest(pool, {
pools.map(([name, pool]) => {
return add(name, async () => {
await runTest(pool, {
@@
-90,4
+90,4
@@
suite(
// eslint-disable-next-line n/no-process-exit
return process.exit()
})
// eslint-disable-next-line n/no-process-exit
return process.exit()
})
- .catch(
err
=> console.error(err))
+ .catch(
(err)
=> console.error(err))