npm-async使用
2024-08-24 15:05:29
async.series(tasks, callback)
tasks可以是对象或数组，返回类型就是参数类型tasks中传入回调函数的第一个值非空即停止后面函数执行- 按照顺序流程进行
async.series({
one: function (cb) {
cb(null, 'one')
},
two: function (cb) {
cb(null, 'two')
}
}, function (err, results) {
console.log(results);
})
async.waterfall(tasks, callback)
- 与
async.series类型 tasks中可以将结果向后传递tasks参数仅可以为数组
async.waterfall([function(cb) {
cb(null, 'one')
}, function (data, cb) {
cb(null, data + ' two')
}], function (err, results) {
console.log(results);
})
async.parallel(tasks, callback)
tasks参数可以是数组或对象tasks函数全部并行执行- 注意最终结果参数还是按照
tasks中声明的顺序
async.parallelLimit(tasks, limit, callback)
- 与
async.parallel相同 limit参数限制最大并发数量
async.queue(work, concurrency)
- 队列流程控制，加强版
paralle() - 队列消息，限制
work数量 - 参数
work是执行任务的回调函数形式,concurrency定义同时执行任务的数量
var async = require('async')
var count = 0;
var queue = async.queue(function (task, cb) {
console.log('work is processing task: ', task.name);
cb();
}, 2)
queue.push({name: 'one'}, function (err) {
setTimeout(function () {
console.log('finished processing foo');
}, 2000)
})
queue.push({name: 'two'}, function (err) {
setTimeout(function () {
console.log('finished processing two');
}, 1000)
})
queue.push({name: 'three'}, function (err) {
console.log('finished processing three');
})
queue.push({name: 'four'}, function (err) {
console.log('finished processing four');
})
//党最后一个任务交给work时调用，所以这里在name:four执行前调用
queue.empty = function () {
console.log('no more tasks wating');
}
//执行完所有任务后调用
queue.drain = function () {
console.log('all tasks have been processed');
}
async.whilst(test, fn, callback)
- 流程控制，相当于
while - 适合以循环的方式执行异步操作
async.whilst(function () {
return count < 5
}, function (cb) {
count++;
setTimeout(function () {
cb(null, count)
}, 1000)
}, function (err, data) {
console.log(data);
})
async.doWhilst(fn, test, callback)
- 与
async.whilst类似, 相当于do...while语句
async.until(test, fn, callback)
async.whilst判断条件相反
async.doUntil(fn, test, callback)
async.doWhilst判断条件相反
最新文章
- 通过js实现回到顶部功能
- MySQL的高可用设计方案的记录
- 【HDU 5363】Key Set
- Cow Bowling
- Python运行Google App Engineer时出现的UnicodeDecodeError错误解决方案
- javascript之事件绑定
- JS的单例模式
- [LeetCode]题解（python）：012-Integer to Roman
- 说说final关键字(好像有干货)
- 如何用Ettercap实现“中间人攻击”（附下载链接）
- (转)CSS颜色及<a>标签超链接颜色改变
- KinectFusion解析
- JavaScript var的作用域和提升
- Lua脚本在redis分布式锁场景的运用
- 机器学习基础环境的安装与使用（MAC版）
- 使用Promise解决多层异步调用的简单学习【转】
- PHP-FPM安装报错解决
- for loop
- linux bash基本特性
- Flutter：修改TextField的高度，以及无边框圆角