From: Jérôme Benoit <jerome.benoit@sap.com>
Date: Thu, 6 Jul 2023 18:44:20 +0000 (+0200)
Subject: feat: add nanothreads to external pools benchmark
X-Git-Tag: v2.6.9~3
X-Git-Url: https://git.piment-noir.org/?a=commitdiff_plain;h=76e2e9784b6912c2bf33f19768ecc2121168110d;p=poolifier.git

feat: add nanothreads to external pools benchmark

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
---

diff --git a/.vscode/settings.json b/.vscode/settings.json
index 867b65ff..002ad7d1 100644
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@@ -24,6 +24,7 @@
     "microtime",
     "mochawesome",
     "MYBENCH",
+    "nanothreads",
     "nocombine",
     "nproc",
     "octocat",
diff --git a/benchmarks/versus-external-pools/fixed-nanothreads.mjs b/benchmarks/versus-external-pools/fixed-nanothreads.mjs
new file mode 100644
index 00000000..4f589e2c
--- /dev/null
+++ b/benchmarks/versus-external-pools/fixed-nanothreads.mjs
@@ -0,0 +1,30 @@
+// IMPORT LIBRARIES
+import { ThreadPool } from 'nanothreads'
+// FINISH IMPORT LIBRARIES
+// IMPORT FUNCTION TO BENCH
+import functionToBench from './functions/function-to-bench.js'
+// FINISH IMPORT FUNCTION TO BENCH
+const size = parseInt(process.env.POOL_SIZE)
+const iterations = parseInt(process.env.NUM_ITERATIONS)
+const data = {
+  test: 'MYBENCH',
+  taskType: process.env.TASK_TYPE,
+  taskSize: parseInt(process.env.TASK_SIZE)
+}
+
+const threadPool = new ThreadPool({
+  task: functionToBench,
+  count: size
+})
+
+async function run () {
+  const promises = new Set()
+  for (let i = 0; i < iterations; i++) {
+    promises.add(threadPool.exec(data))
+  }
+  await Promise.all(promises)
+  // eslint-disable-next-line n/no-process-exit
+  process.exit()
+}
+
+await run()
diff --git a/benchmarks/versus-external-pools/hyperfine_benchmarks.sh b/benchmarks/versus-external-pools/hyperfine_benchmarks.sh
index 67d25af3..594eb446 100755
--- a/benchmarks/versus-external-pools/hyperfine_benchmarks.sh
+++ b/benchmarks/versus-external-pools/hyperfine_benchmarks.sh
@@ -13,3 +13,4 @@ hyperfine --export-markdown BENCH-100000.md --min-runs 20 --prepare 'sleep 5' --
   'node fixed-worker-nodes.js' \
   'node dynamic-node-worker-threads-pool.mjs' \
   'node static-node-worker-threads-pool.mjs' \
+  'node fixed-nanothreads.mjs'
diff --git a/benchmarks/versus-external-pools/package.json b/benchmarks/versus-external-pools/package.json
index 245cca37..6d3a9926 100644
--- a/benchmarks/versus-external-pools/package.json
+++ b/benchmarks/versus-external-pools/package.json
@@ -17,10 +17,11 @@
     "test": "echo \"Error: no test specified\" && exit 1"
   },
   "dependencies": {
+    "nanothreads": "0.3.7",
     "node-worker-threads-pool": "1.5.1",
     "piscina": "4.0.0",
     "poolifier": "2.6.8",
-    "tinypool": "0.6.0",
+    "tinypool": "0.7.0",
     "worker-nodes": "2.6.0",
     "workerpool": "6.4.0"
   }
diff --git a/benchmarks/versus-external-pools/pnpm-lock.yaml b/benchmarks/versus-external-pools/pnpm-lock.yaml
index 08f2d5c8..3224f6ff 100644
--- a/benchmarks/versus-external-pools/pnpm-lock.yaml
+++ b/benchmarks/versus-external-pools/pnpm-lock.yaml
@@ -5,6 +5,9 @@ settings:
   excludeLinksFromLockfile: false
 
 dependencies:
+  nanothreads:
+    specifier: 0.3.7
+    version: 0.3.7
   node-worker-threads-pool:
     specifier: 1.5.1
     version: 1.5.1
@@ -15,8 +18,8 @@ dependencies:
     specifier: 2.6.8
     version: 2.6.8
   tinypool:
-    specifier: 0.6.0
-    version: 0.6.0
+    specifier: 0.7.0
+    version: 0.7.0
   worker-nodes:
     specifier: 2.6.0
     version: 2.6.0
@@ -76,6 +79,10 @@ packages:
       isarray: 1.0.0
     dev: false
 
+  /nanothreads@0.3.7:
+    resolution: {integrity: sha512-l/gbxnQBeMGspLoa+JKhqDrsBtqMW4G5ElsEgbVigR5gl6IBHzBjpM7URGeu0UQN4k7DK0o+J3GmHgaXv+aDQw==}
+    dev: false
+
   /nice-napi@1.0.2:
     resolution: {integrity: sha512-px/KnJAJZf5RuBGcfD+Sp2pAKq0ytz8j+1NehvgIGFkvtvFrDM3T8E4x/JJODXK9WZow8RRGrbA9QQ3hs+pDhA==}
     os: ['!win32']
@@ -121,8 +128,8 @@ packages:
     requiresBuild: true
     dev: false
 
-  /tinypool@0.6.0:
-    resolution: {integrity: sha512-FdswUUo5SxRizcBc6b1GSuLpLjisa8N8qMyYoP3rl+bym+QauhtJP5bvZY1ytt8krKGmMLYIRl36HBZfeAoqhQ==}
+  /tinypool@0.7.0:
+    resolution: {integrity: sha512-zSYNUlYSMhJ6Zdou4cJwo/p7w5nmAH17GRfU/ui3ctvjXFErXXkruT4MWW6poDeXgCaIBlGLrfU6TbTXxyGMww==}
     engines: {node: '>=14.0.0'}
     dev: false