bobolink 轻量级 JS 任务调度工具 项目简介
___. ___. .__ .__ __
\_ |__ ____\_ |__ ____ | | |__| ____ | | __
| __ \ / _ \| __ \ / _ \| | | |/ \| |/ /
| \_\ ( <_> ) \_\ ( <_> ) |_| | | \ <
|___ /\____/|___ /\____/|____/__|___| /__|_ \
\/ \/ \/ \/项目介绍轻量级 JS 任务调度工具，允许并行数控制，超时，重试，错误抓取，运行状态统计等，同时支持多种调度模式，包括立即调度、按频率调度等。为什么说任务执行队列对 JS 来说比其它热门语言更为重要？由于 JS 是事件驱动型的动态脚本语言，我们最常见到的就是在代码里各种各样的异步回调，NodeJs 标榜的轻量高效也是基于 Javascript 非阻塞 I/O 模型而谈的，可以说，基于回调的编程思维是 JS 的一大特色，但有时它会出问题，例如在 for 循环中执行异步任务，由于每个任务都是瞬间返回的，也就是说，循环会很快遍历完，但任务却是堆积的，轻则服务繁忙，重则直接把服务压垮，如何轻巧地控制任务并行量很多时候是一个痛点。安装npm i bobolink使用说明创建一个默认配置的Bobolink按照需要创建一个Bobolink实例（Bobolink实例之间互不影响, 所以可以多种场景使用多个Bobolink，甚至可以通过多个Bobolink合从而应对一些复杂场景）const Bobolink = require('bobolink');
// 每个Bobolink实例都有一个大的队列用于存放任务，所以可以很放心地将任务扔给它，适当的时机下Bobolink会很可靠地调度这些任务。
let q = new Bobolink();put单个任务由于Promise的执行代码在创建的时刻就已经被执行（then和catch内的代码则通过回调执行），所以简单把Promise扔进Bobolink是不可行的// 下面的打印序是 1 2 3
new Promise(resolve => {
console.log(1);
resolve(3)
}).then(res => {
console.log(res);
})
console.log(2)通过将Promise扔进一个function可以达到延期执行的效果function p() {
// 返回promise任务
return new Promise(resolve => {
console.log(1);
resolve(3)
}).then(res => {
console.log(res);
})
}
console.log(2);此时p必须等待调用才会执行内部的Promise代码，且p返回的是该Promise，值便可以继续传递。 每个放置到Bobolink的Promise任务都应该以这种方式封装function p() {
return new Promise(resolve => {
console.log(1);
resolve(2)
}).then(res => {
console.log(res);
return 3;
})
}
// 由于队列很空闲, 可以立即调度本任务,
// 所以很快就成功打印出了1, 之后的then则需要等待合适的时机回调,
// 如果Promise及其上面的所有then都执行完了, 最终会传递到put.then
q.put(p).then(task => {
// 打印最终值3
console.log(task.res)
});当然，如果在put的时候，队列执行中的任务数已经到达最大并行量，则需要等待有任务执行完成时腾出空间，并且排在当前任务之前的任务已经都被调度完了才会得到执行。put一组任务Bobolink允许同时put多个任务，且put.then会在该组任务都被执行完毕时才被调用function getP(flag) {
return function p() {
return new Promise(resolve => {
resolve(flag)
});
}
}
q.put([getP(1), getP(2), getP(3)]).then(tasks => {
// 打印每个任务的返回值, 按放入顺序一一对应
for (let i = 0; i < tasks.length; i++) {
console.log(tasks[i].res);
}
})配置目前支持的参数如下：let q = new Bobolink({
// 最大并行数，最小为1
concurrency: 5,
// 任务超时时间ms，0不超时
timeout: 15000,
// 任务失败重试次数，0不重试
retry: 0,
// 是否优先处理失败重试的任务，为true则失败的任务会被放置到队列头
retryPrior: false,
// 是否优先处理新任务，为true则新任务会被放置到队列头
newPrior: false,
// 最大可排队的任务数, -1为无限制, 超过最大限制时添加任务将返回错误'bobolink_exceeded_maximum_task_number'
max: -1,
// 指定任务的调度模式，仅在初始化时设置有效
scheduling: {
// 默认为'immediately'，任务将在队列空闲时立即得到调度。
// 你也可以将它设置为'frequency', 并且指定countPerSecond, Bobolink将严格地按照设定的频率去调度任务。
enable: 'frequency',
frequency: {
// 每秒需要调度的任务数，仅在任务队列有空闲时才会真正调度。
countPerSecond: 10000
}
},
// 任务失败的handler函数，如果设置了重试，同个任务失败多次会执行catch多次
catch: (err) => {
}
});参数可以在运行期更改, 对后续生效q.setOptions({
concurrency: 5,
timeout: 15000,
retry: 0,
retryPrior: false,
newPrior: false,
catch: null
});任务运行状态使用Bobolink执行的Promise任务所有错误会被catch并包装，所以只存在put.then而不存在put.catch（除非put.then自身出错）。任务执行之后获取到的响应有一些有用的值可以用于服务统计taskRes = {
// 执行是否遇到错误, 判断任务是否执行成功的判断依据是err === undefined, err为任何其它值都代表了运行失败。
// 任务出错时, 如果不重试, 那么catch到的错误会直接放入err, 超时时err为'bobolink_timeout'
// 如果重试, 且在最大重试次数之后依然错误的话, 会将最后一次的错误放入err
// 如果重试, 且在重试期间成功的话, 被认为是成功的, 所以err为空
err: undefined,
// 执行Promise返回的结果
res: Object,
// 从任务放入队列到该任务最后一次被调度, 所经过的时间(ms)
waittingTime: 20,
// 该任务最后一次运行的时间(ms)
runTime: 1,
// 该任务出错重试的次数
retry: 2
}插队除了队列控制参数newPrior和retryPrior之外，也允许在put的时候指定当前任务是否优先处理Bobolink.ptototype.put(tasks, prior)默认情况下，任务是放入队尾的，但如果指定了prior为true，则会被放置到队头，put任务组时会维持组任务原本的顺序，并整个放入队头。更多q.options：获取当前队列的配置。q.queueTaskSize：获取队列排队中的任务数。q.runningTaskCount：获取队列执行中的任务数。
\_ |__ ____\_ |__ ____ | | |__| ____ | | __
| __ \ / _ \| __ \ / _ \| | | |/ \| |/ /
| \_\ ( <_> ) \_\ ( <_> ) |_| | | \ <
|___ /\____/|___ /\____/|____/__|___| /__|_ \
\/ \/ \/ \/项目介绍轻量级 JS 任务调度工具，允许并行数控制，超时，重试，错误抓取，运行状态统计等，同时支持多种调度模式，包括立即调度、按频率调度等。为什么说任务执行队列对 JS 来说比其它热门语言更为重要？由于 JS 是事件驱动型的动态脚本语言，我们最常见到的就是在代码里各种各样的异步回调，NodeJs 标榜的轻量高效也是基于 Javascript 非阻塞 I/O 模型而谈的，可以说，基于回调的编程思维是 JS 的一大特色，但有时它会出问题，例如在 for 循环中执行异步任务，由于每个任务都是瞬间返回的，也就是说，循环会很快遍历完，但任务却是堆积的，轻则服务繁忙，重则直接把服务压垮，如何轻巧地控制任务并行量很多时候是一个痛点。安装npm i bobolink使用说明创建一个默认配置的Bobolink按照需要创建一个Bobolink实例（Bobolink实例之间互不影响, 所以可以多种场景使用多个Bobolink，甚至可以通过多个Bobolink合从而应对一些复杂场景）const Bobolink = require('bobolink');
// 每个Bobolink实例都有一个大的队列用于存放任务，所以可以很放心地将任务扔给它，适当的时机下Bobolink会很可靠地调度这些任务。
let q = new Bobolink();put单个任务由于Promise的执行代码在创建的时刻就已经被执行（then和catch内的代码则通过回调执行），所以简单把Promise扔进Bobolink是不可行的// 下面的打印序是 1 2 3
new Promise(resolve => {
console.log(1);
resolve(3)
}).then(res => {
console.log(res);
})
console.log(2)通过将Promise扔进一个function可以达到延期执行的效果function p() {
// 返回promise任务
return new Promise(resolve => {
console.log(1);
resolve(3)
}).then(res => {
console.log(res);
})
}
console.log(2);此时p必须等待调用才会执行内部的Promise代码，且p返回的是该Promise，值便可以继续传递。 每个放置到Bobolink的Promise任务都应该以这种方式封装function p() {
return new Promise(resolve => {
console.log(1);
resolve(2)
}).then(res => {
console.log(res);
return 3;
})
}
// 由于队列很空闲, 可以立即调度本任务,
// 所以很快就成功打印出了1, 之后的then则需要等待合适的时机回调,
// 如果Promise及其上面的所有then都执行完了, 最终会传递到put.then
q.put(p).then(task => {
// 打印最终值3
console.log(task.res)
});当然，如果在put的时候，队列执行中的任务数已经到达最大并行量，则需要等待有任务执行完成时腾出空间，并且排在当前任务之前的任务已经都被调度完了才会得到执行。put一组任务Bobolink允许同时put多个任务，且put.then会在该组任务都被执行完毕时才被调用function getP(flag) {
return function p() {
return new Promise(resolve => {
resolve(flag)
});
}
}
q.put([getP(1), getP(2), getP(3)]).then(tasks => {
// 打印每个任务的返回值, 按放入顺序一一对应
for (let i = 0; i < tasks.length; i++) {
console.log(tasks[i].res);
}
})配置目前支持的参数如下：let q = new Bobolink({
// 最大并行数，最小为1
concurrency: 5,
// 任务超时时间ms，0不超时
timeout: 15000,
// 任务失败重试次数，0不重试
retry: 0,
// 是否优先处理失败重试的任务，为true则失败的任务会被放置到队列头
retryPrior: false,
// 是否优先处理新任务，为true则新任务会被放置到队列头
newPrior: false,
// 最大可排队的任务数, -1为无限制, 超过最大限制时添加任务将返回错误'bobolink_exceeded_maximum_task_number'
max: -1,
// 指定任务的调度模式，仅在初始化时设置有效
scheduling: {
// 默认为'immediately'，任务将在队列空闲时立即得到调度。
// 你也可以将它设置为'frequency', 并且指定countPerSecond, Bobolink将严格地按照设定的频率去调度任务。
enable: 'frequency',
frequency: {
// 每秒需要调度的任务数，仅在任务队列有空闲时才会真正调度。
countPerSecond: 10000
}
},
// 任务失败的handler函数，如果设置了重试，同个任务失败多次会执行catch多次
catch: (err) => {
}
});参数可以在运行期更改, 对后续生效q.setOptions({
concurrency: 5,
timeout: 15000,
retry: 0,
retryPrior: false,
newPrior: false,
catch: null
});任务运行状态使用Bobolink执行的Promise任务所有错误会被catch并包装，所以只存在put.then而不存在put.catch（除非put.then自身出错）。任务执行之后获取到的响应有一些有用的值可以用于服务统计taskRes = {
// 执行是否遇到错误, 判断任务是否执行成功的判断依据是err === undefined, err为任何其它值都代表了运行失败。
// 任务出错时, 如果不重试, 那么catch到的错误会直接放入err, 超时时err为'bobolink_timeout'
// 如果重试, 且在最大重试次数之后依然错误的话, 会将最后一次的错误放入err
// 如果重试, 且在重试期间成功的话, 被认为是成功的, 所以err为空
err: undefined,
// 执行Promise返回的结果
res: Object,
// 从任务放入队列到该任务最后一次被调度, 所经过的时间(ms)
waittingTime: 20,
// 该任务最后一次运行的时间(ms)
runTime: 1,
// 该任务出错重试的次数
retry: 2
}插队除了队列控制参数newPrior和retryPrior之外，也允许在put的时候指定当前任务是否优先处理Bobolink.ptototype.put(tasks, prior)默认情况下，任务是放入队尾的，但如果指定了prior为true，则会被放置到队头，put任务组时会维持组任务原本的顺序，并整个放入队头。更多q.options：获取当前队列的配置。q.queueTaskSize：获取队列排队中的任务数。q.runningTaskCount：获取队列执行中的任务数。