repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge dependabot/npm_and_yarn/examples/typescript/http-server-pool/fastify-hybrid...
[poolifier.git]
/
benchmarks
/
benchmarks-utils.mjs
diff --git
a/benchmarks/benchmarks-utils.mjs
b/benchmarks/benchmarks-utils.mjs
index 48d5e41b1f0138a589fe4dbee31a762ac92db845..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) => {
@@
-51,6
+53,7
@@
const jsonIntegerSerialization = n => {
}
JSON.stringify(o)
}
}
JSON.stringify(o)
}
+ return { ok: 1 }
}
/**
}
/**
@@
-94,20
+97,21
@@
const readWriteFiles = (
fs.readFileSync(filePath, 'utf8')
}
fs.rmSync(baseDirectory, { recursive: true })
fs.readFileSync(filePath, 'utf8')
}
fs.rmSync(baseDirectory, { recursive: true })
+ 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')
}
}
}
}