task-queue-simple

带超时机制的任务队列实现。

安装

npm install task-queue-simple --save

使用

const TaskQueue = require('task-queue-simple');

const testTaskQueue = new TaskQueue({
    parallel: 3,    //并发任务数量
    timeout: 10000  //任务超时时间，默认-1，永不超时,
    taskInfo: (info) => console.log(info.waiting, info.running) //任务信息。
    delay: 0    //轮询模式，每隔delay指定间隔时间从任务队列取出任务执行。默认0，不设置时间间隔。
});

testTaskQueue
    .processTask((done) => {
        //do something
        
        //执行完任务后，必须调用done方法。
    })
    .catch(err => {
        // err.message === 'timeout' 代表任务超时
    });

testTaskQueue.setTaskTimeout(100);  //设置任务超时时间，只对设置后产生的任务有效。
testTaskQueue.setParallel(20);      //设置并行任务数。