X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=benchmarks%2Fbenchmarks-utils.mjs;h=e8c67583bf1958d7f2f0a2294bd2f1c399ca9b49;hb=a9780ad2992ef19ef824da2d796433fc7f193ec8;hp=c88ada12fa61eda4c474b4142bbd81dbb59ae06d;hpb=30b963d47336380d1878a1feb1bc87f616e0fec6;p=poolifier.git diff --git a/benchmarks/benchmarks-utils.mjs b/benchmarks/benchmarks-utils.mjs index c88ada12..e8c67583 100644 --- 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, - FixedThreadPool + FixedThreadPool, + PoolTypes, + WorkerTypes } from '../lib/index.mjs' -import { PoolTypes, WorkerFunctions, WorkerTypes } from './benchmarks-types.mjs' +import { TaskFunctions } from './benchmarks-types.mjs' export const runTest = async (pool, { taskExecutions, workerData }) => { return new Promise((resolve, reject) => { @@ -21,7 +23,7 @@ export const runTest = async (pool, { taskExecutions, workerData }) => { } return null }) - .catch(err => { + .catch((err) => { console.error(err) return reject(err) }) @@ -44,7 +46,7 @@ export const generateRandomInteger = ( return Math.floor(Math.random() * (max + 1)) } -const jsonIntegerSerialization = n => { +const jsonIntegerSerialization = (n) => { for (let i = 0; i < n; i++) { const o = { a: i @@ -59,7 +61,7 @@ const jsonIntegerSerialization = n => { * @param {number} n - The number of fibonacci numbers to generate. * @returns {number} - The nth fibonacci number. */ -const fibonacci = n => { +const fibonacci = (n) => { if (n <= 1) return n return fibonacci(n - 1) + fibonacci(n - 2) } @@ -69,7 +71,7 @@ const fibonacci = n => { * @param {number} n - The number to calculate the factorial of. * @returns {number} - The factorial of n. */ -const factorial = n => { +const factorial = (n) => { if (n === 0) { return 1 } @@ -98,18 +100,18 @@ const readWriteFiles = ( return { ok: 1 } } -export const executeWorkerFunction = data => { +export const executeTaskFunction = (data) => { switch (data.function) { - case WorkerFunctions.jsonIntegerSerialization: + case TaskFunctions.jsonIntegerSerialization: return jsonIntegerSerialization(data.taskSize || 1000) - case WorkerFunctions.fibonacci: + case TaskFunctions.fibonacci: return fibonacci(data.taskSize || 1000) - case WorkerFunctions.factorial: + case TaskFunctions.factorial: return factorial(data.taskSize || 1000) - case WorkerFunctions.readWriteFiles: + case TaskFunctions.readWriteFiles: return readWriteFiles(data.taskSize || 1000) default: - throw new Error('Unknown worker function') + throw new Error('Unknown task function') } }