use linked list for better performance

CHANGELOG.md

@@ -5,6 +5,10 @@ This project adheres to [Semantic Versioning](http://semver.org/).
 ## Development
 - nothing yet
 
+## v0.0.2
+
+Use new version of linked-list
+
 ## v0.0.1
 
 First version!

package.json

@@ -1,6 +1,6 @@
 {
   "name": "promise-blocking-queue",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Memory optimized promise blocking queue with concurrency control",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -73,6 +73,6 @@
     "typescript": "^3.5.3"
   },
   "dependencies": {
-    "linked-list": "^2.0.1"
+    "linked-list": "^2.1.0"
   }
 }

src/BlockingQueue.ts

@@ -39,7 +39,6 @@ export class BlockingQueue extends (EventEmitter as new() => MessageEmitter) {
     private readonly _queue = new LinkedList<Node<any, any>>();
     private readonly _boundNext: any;
     private _activeCount: number = 0;
-    private _pendingCount: number = 0;
 
     constructor(options: IBlockingQueueOptions) {
         super();
@@ -72,7 +71,6 @@ export class BlockingQueue extends (EventEmitter as new() => MessageEmitter) {
             this._run(item);
         } else {
             this._queue.append(new Node(item));
-            this._pendingCount++;
         }
         return {
             enqueuePromise: enqueuePromiseParts.promise,
@@ -85,7 +83,7 @@ export class BlockingQueue extends (EventEmitter as new() => MessageEmitter) {
     }
 
     public get pendingCount(): number {
-        return this._pendingCount;
+        return this._queue.size;
     }
 
     private _next() {
@@ -94,7 +92,6 @@ export class BlockingQueue extends (EventEmitter as new() => MessageEmitter) {
         const node = this._queue.head;
         if (node) {
             node.detach();
-            this._pendingCount--;
             this._run(node.item);
         } else {
             this.emit('empty');