1.0.3 • Published 7 years ago
task-queue-node v1.0.3
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功能