repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
build: add examples dependencies to dependabot
[poolifier.git]
/
benchmarks
/
benchmarks-utils.mjs
diff --git
a/benchmarks/benchmarks-utils.mjs
b/benchmarks/benchmarks-utils.mjs
index c88ada12fa61eda4c474b4142bbd81dbb59ae06d..259fca5696b0a32c62c040966196ed78f052d9ca 100644
(file)
--- a/
benchmarks/benchmarks-utils.mjs
+++ b/
benchmarks/benchmarks-utils.mjs
@@
-1,12
+1,14
@@
-import crypto from 'crypto'
-import fs from 'fs'
+import crypto from '
node:
crypto'
+import fs from '
node:
fs'
import {
DynamicClusterPool,
DynamicThreadPool,
FixedClusterPool,
import {
DynamicClusterPool,
DynamicThreadPool,
FixedClusterPool,
- FixedThreadPool
+ FixedThreadPool,
+ PoolTypes,
+ WorkerTypes
} from '../lib/index.mjs'
} from '../lib/index.mjs'
-import {
PoolTypes, WorkerFunctions, WorkerType
s } from './benchmarks-types.mjs'
+import {
TaskFunction
s } from './benchmarks-types.mjs'
export const runTest = async (pool, { taskExecutions, workerData }) => {
return new Promise((resolve, reject) => {
export const runTest = async (pool, { taskExecutions, workerData }) => {
return new Promise((resolve, reject) => {
@@
-98,18
+100,18
@@
const readWriteFiles = (
return { ok: 1 }
}
return { ok: 1 }
}
-export const execute
Worker
Function = data => {
+export const execute
Task
Function = data => {
switch (data.function) {
switch (data.function) {
- case
Worker
Functions.jsonIntegerSerialization:
+ case
Task
Functions.jsonIntegerSerialization:
return jsonIntegerSerialization(data.taskSize || 1000)
return jsonIntegerSerialization(data.taskSize || 1000)
- case
Worker
Functions.fibonacci:
+ case
Task
Functions.fibonacci:
return fibonacci(data.taskSize || 1000)
return fibonacci(data.taskSize || 1000)
- case
Worker
Functions.factorial:
+ case
Task
Functions.factorial:
return factorial(data.taskSize || 1000)
return factorial(data.taskSize || 1000)
- case
Worker
Functions.readWriteFiles:
+ case
Task
Functions.readWriteFiles:
return readWriteFiles(data.taskSize || 1000)
default:
return readWriteFiles(data.taskSize || 1000)
default:
- throw new Error('Unknown
worker
function')
+ throw new Error('Unknown
task
function')
}
}
}
}