Bump expect from 26.6.0 to 26.6.1

[poolifier.git] / lib / dynamic.js

diff --git a/lib/dynamic.js b/lib/dynamic.js
index fa8a3a521c96b0b01954dcf303a7264308e541b0..36db0c75673ed7a70d4fe5e6e634b2754c38529f 100644 (file)
--- a/lib/dynamic.js
+++ b/lib/dynamic.js
@@ -1,11 +1,12 @@
 'use strict'
 const FixedThreadPool = require('./fixed')
+const EventEmitter = require('events')
+class MyEmitter extends EventEmitter {}
 
 /**
  * A thread pool with a min/max number of threads , is possible to execute tasks in sync or async mode as you prefer. <br>
  * This thread pool will create new workers when the other ones are busy, until the max number of threads,
- * when the max number of threads is reached, an exception will be thrown.
- * This pool will select the worker thread in a round robin fashion. <br>
+ * when the max number of threads is reached, an event will be emitted , if you want to listen this event use the emitter method.
  * @author Alessandro Pio Ardizio
  * @since 0.0.1
  */
@@ -14,11 +15,11 @@ class DynamicThreadPool extends FixedThreadPool {
     *
     * @param {Number} min  Min number of threads that will be always active
     * @param {Number} max  Max number of threads that will be active
-    * @param {Object} an object with possible options for example maxConcurrency
   */
   constructor (min, max, filename, opts) {
     super(min, filename, opts)
     this.max = max
+    this.emitter = new MyEmitter()
   }
 
   _chooseWorker () {
@@ -35,7 +36,8 @@ class DynamicThreadPool extends FixedThreadPool {
       return worker
     } else {
       if (this.workers.length === this.max) {
-        throw new Error('Max number of threads reached !!!')
+        this.emitter.emit('FullPool')
+        return super._chooseWorker()
       }
       // all workers are busy create a new worker
       const worker = this._newWorker()