pro_queue v1.0.0

很多项目可能都会涉及到任务队列来进行任务处理和维护的，那么需要使用到redis或者第三方库（使用redis）来实现任务队列，甚至需要控制并发量，但是对于saas部署来说使用redis可能会比较麻烦和成本提升，那么我们是否可以直接基于程序来使用内存进行任务队列管理，有兴趣可以了解一下这个包：pro_queue github地址

介绍

该包是借鉴bee-queue github地址库的外部接口规范来对外统一提供任务的创建和执行（设置任务执行相关的数据【间隔、并发、任务处理等】），该包已经支持同时多任务队列管理且处理任务。

使用

// 创建新的队列
const Queue = require('../index');
const testQueue = Queue.newQueue('test');

testQueue.createdJob({a: 'test'});

// test队列设置任务处理及间隔
testQueue.process(1000, (job, done)=>{
  console.log(`\r\nstart queue test process job:`, job.id, job.data);
  return done();
}, true);
testQueue.createdJob({a: 'test'});

关于异步和同步执行队列使用详情请参考根目录下test目录下源码

API

createdJob(any)

process(timeout, callback, sync)

待实现功能计划

任务失败重试，可设置重试次数

并发数量

任务执行结果时间

succeeded：任务成功执行

retrying：任务失败需要重新尝试，且剩余尝试次数

failed：任务失败，且没有重试次数

progress：

队列数据持久化

防止程序中断或异常终止时重启程序，队列数据丢失