refactor(examples): trivial code cleanups
authorJérôme Benoit <jerome.benoit@piment-noir.org>
Mon, 1 Apr 2024 15:08:16 +0000 (17:08 +0200)
committerJérôme Benoit <jerome.benoit@piment-noir.org>
Mon, 1 Apr 2024 15:08:16 +0000 (17:08 +0200)
Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
README.md
examples/javascript/dynamicExample.cjs
examples/javascript/fixedExample.cjs
examples/javascript/multiFunctionExample.cjs
examples/typescript/pool.ts

index 6f6e79c7cb91e089e1e3a8996446f58f38bffa82..db52c8c2c8ebb92fc50c2912a4875a6519750c99 100644 (file)
--- a/README.md
+++ b/README.md
@@ -120,8 +120,8 @@ import { DynamicThreadPool, FixedThreadPool, PoolEvents, availableParallelism }
 
 // a fixed worker_threads pool
 const pool = new FixedThreadPool(availableParallelism(), './yourWorker.js', {
-  errorHandler: e => console.error(e),
-  onlineHandler: () => console.info('worker is online')
+  onlineHandler: () => console.info('worker is online'),
+  errorHandler: e => console.error(e)
 })
 
 pool.emitter?.on(PoolEvents.ready, () => console.info('Pool is ready'))
@@ -129,8 +129,8 @@ pool.emitter?.on(PoolEvents.busy, () => console.info('Pool is busy'))
 
 // or a dynamic worker_threads pool
 const pool = new DynamicThreadPool(Math.floor(availableParallelism() / 2), availableParallelism(), './yourWorker.js', {
-  errorHandler: e => console.error(e),
-  onlineHandler: () => console.info('worker is online')
+  onlineHandler: () => console.info('worker is online'),
+  errorHandler: e => console.error(e)
 })
 
 pool.emitter?.on(PoolEvents.full, () => console.info('Pool is full'))
index e170f59c00d35b24e54693da0a96f909f5dc73b8..a72ce3a6a6cd07e587686ce25c4c0083ce334aa8 100644 (file)
@@ -10,8 +10,8 @@ const pool = new DynamicThreadPool(
   availableParallelism(),
   './yourWorker.js',
   {
-    errorHandler: e => console.error(e),
-    onlineHandler: () => console.info('worker is online')
+    onlineHandler: () => console.info('worker is online'),
+    errorHandler: e => console.error(e)
   }
 )
 let poolFull = 0
index 38e0c8afbe30a66e2ab66dba1a7a2d152d6d4b01..f191aa24d7d25e07e8bd3b9ff8eff0e02442482c 100644 (file)
@@ -6,8 +6,8 @@ const {
 } = require('poolifier')
 
 const pool = new FixedThreadPool(availableParallelism(), './yourWorker.cjs', {
-  errorHandler: e => console.error(e),
-  onlineHandler: () => console.info('worker is online')
+  onlineHandler: () => console.info('worker is online'),
+  errorHandler: e => console.error(e)
 })
 let poolReady = 0
 let poolBusy = 0
index 7ab57ab72a5f689b870f210bbc1fc8c9d0a08c70..643d117a2b8bcdeeaec5be9a61fe7272ce773dd7 100644 (file)
@@ -5,8 +5,8 @@ const pool = new FixedThreadPool(
   availableParallelism(),
   './multiFunctionWorker.cjs',
   {
-    errorHandler: e => console.error(e),
-    onlineHandler: () => console.info('worker is online')
+    onlineHandler: () => console.info('worker is online'),
+    errorHandler: e => console.error(e)
   }
 )
 
index fb48f7b07db76324a75afc001e131dd448a6809f..3965e1f0a1cd4c8e2632b59018972e79fa5b798e 100644 (file)
@@ -18,11 +18,11 @@ const fixedPool = new FixedThreadPool<MyData, MyResponse>(
   availableParallelism(),
   workerFile,
   {
-    errorHandler: (e: Error) => {
-      console.error(e)
-    },
     onlineHandler: () => {
       console.info('Worker is online')
+    },
+    errorHandler: (e: Error) => {
+      console.error(e)
     }
   }
 )
@@ -34,11 +34,11 @@ const dynamicPool = new DynamicThreadPool<MyData, MyResponse>(
   availableParallelism(),
   workerFile,
   {
-    errorHandler: (e: Error) => {
-      console.error(e)
-    },
     onlineHandler: () => {
       console.info('Worker is online')
+    },
+    errorHandler: (e: Error) => {
+      console.error(e)
     }
   }
 )