X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=benchmarks%2Finternal%2Fbench.mjs;h=3f467f9ea49689d642a4b9eae087416d806a9735;hb=a70d17c01f1a59c1525fed69c7cec2c3f4cf5175;hp=480998b72c935900681627839091162befbd6a23;hpb=16534b4212013e58407946c95a53db4d8512d512;p=poolifier.git diff --git a/benchmarks/internal/bench.mjs b/benchmarks/internal/bench.mjs index 480998b7..3f467f9e 100644 --- a/benchmarks/internal/bench.mjs +++ b/benchmarks/internal/bench.mjs @@ -1,4 +1,6 @@ -import { exit } from 'node:process' +import { writeFileSync } from 'node:fs' +import { env } from 'node:process' +// eslint-disable-next-line n/no-unsupported-features/node-builtins import { parseArgs } from 'node:util' import { @@ -8,16 +10,18 @@ import { } from '../../lib/index.mjs' import { TaskFunctions } from '../benchmarks-types.cjs' import { - runPoolifierBenchmarkBenchmarkJsSuite, - runPoolifierBenchmarkMitata + convertTatamiNgToBmf, + runPoolifierBenchmarkTatamiNg } from '../benchmarks-utils.mjs' const poolSize = availableParallelism() const taskExecutions = 1 const workerData = { function: TaskFunctions.factorial, - taskSize: 50000 + taskSize: 1000 } +const benchmarkReportFile = 'benchmark-report.json' +let benchmarkReport switch ( parseArgs({ @@ -32,91 +36,66 @@ switch ( allowPositionals: true }).values.type ) { - case 'mitata': - await runPoolifierBenchmarkMitata( - 'FixedThreadPool', - WorkerTypes.thread, - PoolTypes.fixed, - poolSize, - { - taskExecutions, - workerData - } - ) - await runPoolifierBenchmarkMitata( - 'DynamicThreadPool', - WorkerTypes.thread, - PoolTypes.dynamic, - poolSize, - { - taskExecutions, - workerData - } - ) - await runPoolifierBenchmarkMitata( - 'FixedClusterPool', - WorkerTypes.cluster, - PoolTypes.fixed, - poolSize, - { - taskExecutions, - workerData - } - ) - await runPoolifierBenchmarkMitata( - 'DynamicClusterPool', - WorkerTypes.cluster, - PoolTypes.dynamic, - poolSize, - { - taskExecutions, - workerData - } - ) - break - case 'benchmark.js': + case 'tatami-ng': default: - await runPoolifierBenchmarkBenchmarkJsSuite( - 'FixedThreadPool', - WorkerTypes.thread, - PoolTypes.fixed, - poolSize, - { - taskExecutions, - workerData - } - ) - await runPoolifierBenchmarkBenchmarkJsSuite( - 'DynamicThreadPool', - WorkerTypes.thread, - PoolTypes.dynamic, - poolSize, - { - taskExecutions, - workerData - } - ) - await runPoolifierBenchmarkBenchmarkJsSuite( - 'FixedClusterPool', - WorkerTypes.cluster, - PoolTypes.fixed, - poolSize, - { - taskExecutions, - workerData - } - ) - await runPoolifierBenchmarkBenchmarkJsSuite( - 'DynamicClusterPool', - WorkerTypes.cluster, - PoolTypes.dynamic, - poolSize, - { - taskExecutions, - workerData - } + benchmarkReport = convertTatamiNgToBmf( + await runPoolifierBenchmarkTatamiNg( + 'FixedThreadPool', + WorkerTypes.thread, + PoolTypes.fixed, + poolSize, + { + taskExecutions, + workerData + } + ) ) + benchmarkReport = { + ...benchmarkReport, + ...convertTatamiNgToBmf( + await runPoolifierBenchmarkTatamiNg( + 'DynamicThreadPool', + WorkerTypes.thread, + PoolTypes.dynamic, + poolSize, + { + taskExecutions, + workerData + } + ) + ) + } + benchmarkReport = { + ...benchmarkReport, + ...convertTatamiNgToBmf( + await runPoolifierBenchmarkTatamiNg( + 'FixedClusterPool', + WorkerTypes.cluster, + PoolTypes.fixed, + poolSize, + { + taskExecutions, + workerData + } + ) + ) + } + benchmarkReport = { + ...benchmarkReport, + ...convertTatamiNgToBmf( + await runPoolifierBenchmarkTatamiNg( + 'DynamicClusterPool', + WorkerTypes.cluster, + PoolTypes.dynamic, + poolSize, + { + taskExecutions, + workerData + } + ) + ) + } + env.CI != null && + writeFileSync(benchmarkReportFile, JSON.stringify(benchmarkReport)) break } - -exit()