TODO added
authoraardizio <alessandroardizio94@gmail.com>
Sun, 19 Jan 2020 14:07:07 +0000 (15:07 +0100)
committeraardizio <alessandroardizio94@gmail.com>
Sun, 19 Jan 2020 14:07:07 +0000 (15:07 +0100)
lib/fixed.js

index 5d5d40e1be1a53c8092360432f97f77a97d57e41..95fe686218c5758997cf1111e2f8148d08e32f6d 100644 (file)
@@ -83,8 +83,10 @@ class FixedThreadPool {
   _newWorker () {
     const worker = new Worker(path.resolve(this.filename), { env: SHARE_ENV })
     worker.on('error', this.opts.errorHandler || empty)
-    worker.on('exit', this.opts.exitHandler || empty)
     worker.on('online', this.opts.onlineHandler || empty)
+    // TODO remove the workers array , use only the map data structure
+    // handle properly when a thread exit
+    worker.on('exit', this.opts.exitHandler || empty)
     this.workers.push(worker)
     const { port1, port2 } = new MessageChannel()
     worker.postMessage({ parent: port1 }, [port1])