task-queue-node

Install

npm install task-queue-node --save 

Usage

    var taskQueue = require('./index')
    var Promise = require('bluebird')
    var request = require('request')
    
    var task = taskQueue.createTask({
      interval: 200,
      wait: true,
      taskCommand: function (args) { // taskCommand must return promise
        return new Promise(function (resolve, reject) {
          console.log(new Date().getTime(), args)
          setTimeout(() => {
            resolve(args + ' success')
          }, 300)
        })
      },
      autoStart: false
    })
    
    // Use multiple taskQueue
    var task1 = taskQueue.createTask({
      interval: 200,
      wait: true,
      taskCommand: commandFunc,
      max: 20
    })
    var commandFunc = function(){
        return new Promise(function (resolve, reject) {
          request('http://www.baidu.com',function(){
            resolve(args + ' success')
          })
        })
    }
    
    // listen every task execute complate event
    task1.subscribe((err, result) => { //result is taskCommand resolve
      if (err) {
        console.error(err, 'subscribe')
      } else {
        console.log(result)
      }
    })

Example

• See the test.js file for more examples.

Params && Event

Params	Description
interval	task execute interval(ms),default:1000.
key	queue name,default:taskQueue.
autoStart	when the queue is empty,use addQueue auto execute start event, default:true.
wait	The next task will wait taskCommand resolve for execution, default:false.
ignoreError	set the false,taskCommand reject stop all task when, default:true.
taskCommand	task's Processing method,must is return promise,you can use bluebird.
firstDelay	first task is delay default:true (Not realized).
max	queue max task number,beyond will be truncated before default:0,set 0 no limit.

Event	Description
start	start execute task.
stop	stop execute task.
restart	restart task queue.
clear	clear queue.
addQueue	add task to queue.
subscribe	subscribe taskCommand resolve and reject event.
removeSubscribe	remove subscribe event.

TODO

• 集成redis用于分布式部署
• 实现firstDelay功能