repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
fix: fix pool ready event emission
[poolifier.git]
/
benchmarks
/
internal
/
bench.mjs
diff --git
a/benchmarks/internal/bench.mjs
b/benchmarks/internal/bench.mjs
index 7ef61bc6cba31225a4d8732b721422494deeb4d3..adff36153241f7843f702547237280a509bb7326 100644
(file)
--- a/
benchmarks/internal/bench.mjs
+++ b/
benchmarks/internal/bench.mjs
@@
-4,10
+4,7
@@
import {
availableParallelism
} from '../../lib/index.mjs'
import { TaskFunctions } from '../benchmarks-types.js'
availableParallelism
} from '../../lib/index.mjs'
import { TaskFunctions } from '../benchmarks-types.js'
-import {
- buildPoolifierPool,
- runPoolifierPoolBenchmark
-} from '../benchmarks-utils.js'
+import { runPoolifierPoolBenchmark } from '../benchmarks-utils.js'
const poolSize = availableParallelism()
const taskExecutions = 1
const poolSize = availableParallelism()
const taskExecutions = 1
@@
-18,8
+15,10
@@
const workerData = {
// FixedThreadPool
await runPoolifierPoolBenchmark(
// FixedThreadPool
await runPoolifierPoolBenchmark(
- 'Poolifier FixedThreadPool',
- buildPoolifierPool(WorkerTypes.thread, PoolTypes.fixed, poolSize),
+ 'FixedThreadPool',
+ WorkerTypes.thread,
+ PoolTypes.fixed,
+ poolSize,
{
taskExecutions,
workerData
{
taskExecutions,
workerData
@@
-28,8
+27,10
@@
await runPoolifierPoolBenchmark(
// DynamicThreadPool
await runPoolifierPoolBenchmark(
// DynamicThreadPool
await runPoolifierPoolBenchmark(
- 'Poolifier DynamicThreadPool',
- buildPoolifierPool(WorkerTypes.thread, PoolTypes.dynamic, poolSize),
+ 'DynamicThreadPool',
+ WorkerTypes.thread,
+ PoolTypes.dynamic,
+ poolSize,
{
taskExecutions,
workerData
{
taskExecutions,
workerData
@@
-38,8
+39,10
@@
await runPoolifierPoolBenchmark(
// FixedClusterPool
await runPoolifierPoolBenchmark(
// FixedClusterPool
await runPoolifierPoolBenchmark(
- 'Poolifier FixedClusterPool',
- buildPoolifierPool(WorkerTypes.cluster, PoolTypes.fixed, poolSize),
+ 'FixedClusterPool',
+ WorkerTypes.cluster,
+ PoolTypes.fixed,
+ poolSize,
{
taskExecutions,
workerData
{
taskExecutions,
workerData
@@
-48,8
+51,10
@@
await runPoolifierPoolBenchmark(
// DynamicClusterPool
await runPoolifierPoolBenchmark(
// DynamicClusterPool
await runPoolifierPoolBenchmark(
- 'Poolifier DynamicClusterPool',
- buildPoolifierPool(WorkerTypes.cluster, PoolTypes.dynamic, poolSize),
+ 'DynamicClusterPool',
+ WorkerTypes.cluster,
+ PoolTypes.dynamic,
+ poolSize,
{
taskExecutions,
workerData
{
taskExecutions,
workerData