* Add benchmark

* Improve performance(Use LinkList)

Author: Flare

README.md

@@ -15,6 +15,37 @@ $ npm install wait-queue
 
 [ES5 version](https://github.com/flarestart/wait-queue-es5)
 
+## Benchmark
+
+```
+$ npm install
+$ npm run benchmark
+```
+
+Sample data in Macbook Pro MF839/8GB
+
+### 1.0.3(Use LinkList)
+
+    .push() 1k data speed test x 511,367 ops/sec ±31.07% (27 runs sampled)
+    .unshift() 1k data speed test x 269,995 ops/sec ±39.60% (14 runs sampled)
+    .push() 4k data speed test x 41,531 ops/sec ±12.20% (7 runs sampled)
+    .unshift() 4k data speed test x 35,928 ops/sec ±5.11% (8 runs sampled)
+    .shift() 69614.33093950555 /s
+
+### 1.0.2(Use Array)
+
+    .push() 1k data speed test x 554,552 ops/sec ±26.09% (25 runs sampled)
+    .unshift() 1k data speed test x 132 ops/sec ±2.96% (72 runs sampled)
+    .push() 4k data speed test x 75,107 ops/sec ±22.32% (9 runs sampled)
+    .unshift() 4k data speed test x 115 ops/sec ±2.15% (71 runs sampled)
+    .shift() `wait too long, I didn't wait for the result, I guess is about 110/s`
+
+## Change log
+
+### 1.0.3
+
+ * Replace `wq.queue` from `Array` to `LinkList`, because do shift() operation on `Array` of 10,000,000 items cost too many time
+
 ## Simple Example
 
 ```js

benchmark/index.js

@@ -0,0 +1,54 @@
+var Benchmark = require('benchmark');
+var suite = new Benchmark.Suite;
+var WaitQueue = require('../index')
+var wq = new WaitQueue
+
+var TimeStart = Date.now()
+var End = new Error('end')
+var Count = 0
+
+// add a default consumer
+function loop(){
+    wq.shift()
+    .then(function(item){
+        // end loop, output shift speed
+        if(item === End){
+            console.log('.shift()', Count * 1000 / (Date.now() - TimeStart), '/s');
+        }
+        setImmediate(loop)
+    })
+    .catch(function(e){
+        console.log(e)
+    })
+}
+// start loop
+loop()
+
+// test push speed
+suite.add('.push() 1k data speed test', function () {
+    Count++
+    wq.push(Buffer.allocUnsafe(1024))
+})
+suite.add('.unshift() 1k data speed test', function () {
+    Count++
+    wq.unshift(Buffer.allocUnsafe(1024))
+})
+suite.add('.push() 4k data speed test', function () {
+    Count++
+    wq.push(Buffer.allocUnsafe(4096))
+})
+suite.add('.unshift() 4k data speed test', function () {
+    Count++
+    wq.unshift(Buffer.allocUnsafe(4096))
+})
+
+suite.on('cycle', function(event) {
+    console.log(String(event.target));
+})
+.on('error', function(err){
+    console.log(err)
+})
+.on('complete', function() {
+    wq.push(End)
+})
+.run({ async: true })

index.js

@@ -4,6 +4,7 @@
  */
 'use strict'
 const EventEmitter = require('events').EventEmitter
+const LinkList = require('./libs/LinkList')
 
 class TerminateError extends Error{
 	constructor(message){
@@ -15,7 +16,7 @@ class TerminateError extends Error{
 class WaitQueue extends EventEmitter{
 	constructor(){
 		super()
-		this.queue = []
+		this.queue = new LinkList
 		this.listeners = []
 		this.terminated = false
 	}
@@ -35,7 +36,7 @@ class WaitQueue extends EventEmitter{
 		}
 	}
 	empty(){
-		this.queue = []
+		this.queue = new LinkList
 	}
 	unshift(item){
 		let success = false
@@ -91,7 +92,7 @@ class WaitQueue extends EventEmitter{
 	}
 	terminate(){
 		this.terminated = true
-		this.queue = []
+		this.queue = new LinkList
 		this._flush()
 		this.emit('terminate')
 	}

libs/LinkList.js

@@ -0,0 +1,77 @@
+/*
+ * Javascript WaitQueue Object in ES5
+ * https://github.com/flarestart/wait-queue-es5
+ */
+'use strict';
+
+function LinkList() {
+    this.length = 0;
+    this._front = null;
+    this._end = null;
+}
+LinkList.prototype.push = function (item) {
+    var node = {
+        item: item,
+        _next: null,
+        _prev: null
+    };
+    if (this.length <= 0) {
+        this._front = node;
+        this._end = node;
+    } else {
+        this._end._next = node;
+        node._prev = this._end;
+        this._end = node;
+    }
+    this.length++;
+};
+LinkList.prototype.shift = function () {
+    var item = this._front;
+    if (item === null) {
+        return null;
+    }
+    if (this._front._next != null) {
+        this._front = this._front._next;
+        this._front._prev = null;
+    } else {
+        this._front = null;
+        this._end = null;
+    }
+    item._next = undefined;
+    this.length--;
+    return item.item;
+};
+LinkList.prototype.unshift = function (item) {
+    var node = {
+        item: item,
+        _next: null,
+        _prev: null
+    };
+    if (this.length <= 0) {
+        this._front = node;
+        this._end = node;
+    } else {
+        node._next = this._front;
+        this._front._prev = node;
+        this._front = node;
+    }
+    this.length++;
+};
+LinkList.prototype.pop = function () {
+    var item = this._end;
+    if (item === null) {
+        return null;
+    }
+    if (this._end._prev != null) {
+        this._end = this._end._prev;
+        this._end._next = null;
+    } else {
+        this._front = null;
+        this._end = null;
+    }
+    this.length--;
+    item._prev = undefined;
+    return item.item;
+};
+
+module.exports = LinkList;

package.json

@@ -1,13 +1,14 @@
 {
   "name": "wait-queue",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "description": "A javascript wait queue object handle infinity loop tasks more efficiently (using ES6 class and promise)",
   "main": "index.js",
   "directories": {
     "test": "tests"
   },
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "test": "echo \"Error: no test specified\" && exit 1",
+    "benchmark": "node ./benchmark/"
   },
   "repository": {
     "type": "git",
@@ -25,6 +26,7 @@
   },
   "homepage": "https://github.com/flarestart/wait-queue#readme",
   "devDependencies": {
+    "benchmark": "^2.1.3",
     "co": "^4.6.0"
   }
 }