node.js async流程控制器--queue(队列)

queue流程控制器是一个并行的流程控制器,但是它与parallel的区别在于queue可以控制一次执行几个函数,而parallel只是让所有函数并行执行.

例子如下:

var q = async.queue(function (obj,cb) {setTimeout(function () {console.log(obj);cb();
},obj.time)
},1)for (var i = 0; i<100; i++) {
  
console.log(1);
  
  q.push({name:i,time:i*1000},function (err) {
      console.log(err);
  }) };
for (var i = 0; i<100; i++) {console.log(2);q.push({name:1,time:1000},function (err) {
    console.log(err);
  }) };

 

这里用了一个伪异步执行的方式,queue的参数有两个,第一个是一个函数,第二个是执行的进程数,第一个参数又包含两个参数,第一个是传递的对象,第二个是回调函数,例子中只有在console.log(obj)执行完后调用cb();队列才会往下执行,queue会返回一个标识符(例子中的q).

例子中的q.push是往队列中添加数据(会被queue里的obj接收),第二个参数是一个回调函数,如果有异常会触发此回调函数。例子中每次只插入一个数据,也可以插入多个例如q.push([{name:0,time:1000}],{name:1,time:2000}]);(这里是个数组).

这里为了确认循环是否真的执行,所以在循环中打印了两个数字.执行的结果是先循环打印了console.log(1)然后再循环打印了console.log(2),这里说明  确实两个循环执行到了,然后会先把第一个循环加入到queue里的对象打出来,然后把第二个循环打印出来,充分遵守了队列的性质:先进先出,后进后出的规则,不会因为因为执行的时间而使得结果混乱.如果把queue里的工作数改为2,则会每次打印两个.

 

queue还有几个函数,比如:

worker数量将用完时,会调用saturated函数:

q.saturated = function() { log(‘all workers to be used’); 
}

 

当最后一个任务交给worker执行时,会调用empty函数

q.empty = function() { log(‘no more tasks wating’); 
}

 

当所有任务都执行完时,会调用drain函数

q.drain = function() { console.log(‘all tasks have been processed’); 
}

 

转载于:https://www.cnblogs.com/tudou1223/p/4151851.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/259633.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

利用JS实现点击上一周或下一周却换

1.页面加载显示当前年份的第几周 效果如图&#xff1a; html代码&#xff1a; <font size"2" color"black"> <input id"btnweek5" type"button" class"btn" value"上周" οnclick"EduCommissio…

centos7网卡编辑_CentOS7修改网卡为eth0

1.编辑网卡信息[rootlinux-node2~]#cd /etc/sysconfig/network-scripts/ #进入网卡目录[rootlinux-node2network-scripts]# mv ifcfg-eno16777728 ifcfg-eth0 #重命名网卡名称[rootlinux-node2 network-scripts]#cat ifcfg-eth0 #编辑网卡信息TYPEEthernetBOOTPROTOstaticDEFR…

C# 微支付退款申请接口 V3.3.6

/// <summary>/// 微支付退款申请/// </summary>/// <param name"context"></param>/// <param name"returnMsg"></param>/// <returns></returns>public bool Refund(HttpContext context, ref string r…

[转] 英语、计算机、互联网与全球化

http://davidzhao.blog.51cto.com/4548102/1225732 转载于:https://www.cnblogs.com/wowk/p/3169638.html

APNIC IP 库

http://ftp.apnic.net/apnic/stats/apnic/delegated-apnic-latest转载于:https://www.cnblogs.com/dlwj/p/6388162.html

java reference 传引用_Java的引用(reference)---Roni

摘自《Java面向对象编程》一书,作者:孙卫琴 来源:www.javathinker.org在JDK1.2以前的版本中&#xff0c;当一个对象不被任何变量引用&#xff0c;那么程序就无法再使用这个对象。也就是说&#xff0c;只有对象处于可触及状态&#xff0c;程序才能使用它。这就像在日常生活中&am…

C# 以管理员身份运行程序

刚看了一篇博友写的“以管理员身份运行程序”, 所以我也来写一个简单易懂的&#xff0c;简单两步搞定&#xff0c;不用写任何代码&#xff1a; 第一步&#xff1a; 右键选择项目 > 添加 > 新建项 &#xff1b; 找到 应用程序清单文件&#xff0c;后缀名为manifest&#x…

会计转行从事IT,如何在一年时间内全职学习?

2019独角兽企业重金招聘Python工程师标准>>> https://www.zhihu.com/question/21427478/answer/18227060 转载于:https://my.oschina.net/soho00147/blog/836138

VS2010中使用CL快速 生成DLL的方法

方案一&#xff1a; 1、命令行中输入cl example.cpp&#xff0c;生成example.obj和example.lib文件。有可能还会提示“没有入口点”的错误。这是因为我们的CPP中是要生成dll文件的&#xff0c;并没有main()这样的主函数作为入口点。如果是C文件&#xff0c;则输入cl /c exampl…

java field 获得值_反射通用获取字段值

像之前回答的那样&#xff0c;您应该使用&#xff1a;Object value field.get(objectInstance);有时更喜欢的另一种方法是动态调用getter。示例代码&#xff1a;public static Object runGetter(Field field, BaseValidationObject o){// MZ: Find the correct methodfor (Met…

android 中如何模拟back键

主要是在使用Fragment时能够返回前一级&#xff0c;所以才找到了这些资料。 有两种方式可以实现&#xff0c;直接上代码 方法1&#xff1a; public void onBack(){new Thread(){public void run() {try{Instrumentation inst new Instrumentation();inst.sendKeyDownUpSync(Ke…

如何生成后缀表达式

如果计算一个表达式&#xff0c;比如 456*2&#xff0c;随着计算器的不同&#xff0c;简单的四功能计算器是30&#xff0c;许多科学计算器知道乘法的优先级高于加法&#xff0c;所以科学答案是21。典型计算顺序可以是计算45&#xff0c;存为临时变量a&#xff0c;再计算6*2&…

【原生JS插件】LoadingBar页面顶部加载进度条

先展示一下已经实现的效果&#xff1a; 预览地址&#xff1a;http://dtdxrk.github.io/js-plug/LoadingBar/index.html 看到手机上的浏览器内置了页面的加载进度条&#xff0c;想用在pc上。 网上搜了一下&#xff0c;看到几种页面loading的方法&#xff1a; 1.在body头部加入lo…

qtp启动java程序_转: QTP六脉神剑之调用Java程序

查看( 1147 ) /评论( 21 )六脉神剑之调用程序0Xp1zLN_0版权声明&#xff1a;原创作品&#xff0c;转载请以链接方式注明出自http://www.51testing.com/?35&#xff0c;否则将追究法律责任。51Testing软件测试网y|X,taS51Testing软件测试网b;|w6I"g6oK本文出自songfun的51…

Linq 数据库操作(增删改查)

Linq数据库增删改查 Linq是一种查询语言&#xff0c;集成包含在formwork中&#xff0c;包含在C#语言中&#xff0c;它的作用是降低查询的门槛&#xff0c;提高开发效率&#xff0c;是我们必须掌握的技术之一&#xff0c;下面是我自己对linq数据库操作的方法&#xff0c;与大家…

第八章 Python 对象和类

一、什么是对象 在 Pyth 中&#xff0c;对象就是经过实例化的&#xff0c;具体可以操作的一组代码的组合&#xff1b; 对象一般包含数据&#xff08;变量&#xff0c;更习惯称之为属性 attribute&#xff09;&#xff0c;也包含代码&#xff08;函数&#xff0c;也称之为方法&a…

JS同名方法,

JS同名方法只会调用最后一个方法。 JS中同时绑定多个事件&#xff0c;先绑定的先调用。后绑定的后调用。转载于:https://www.cnblogs.com/daishuguang/p/4169718.html

Spring WebSocket初探2 (Spring WebSocket入门教程)

2019独角兽企业重金招聘Python工程师标准>>> WebSocket前端准备 SockJS&#xff1a; SockJS 是一个浏览器上运行的 JavaScript 库&#xff0c;如果浏览器不支持 WebSocket&#xff0c;该库可以模拟对 WebSocket 的支持&#xff0c;实现浏览器和 Web 服务器之间低延迟…

软件测试相关概念与分类

这是我看了有关软件测试的书的一些归纳与总结。 软件测试的核心是发现软件中的缺陷。测试是对软件质量的度量。 一、缺陷 缺陷&#xff0c;目前没有标准定义 。与缺陷相关的一组定义就有&#xff1a;软件错误、软件缺陷、软件故障、软件失效。 软件错误&#xff1a;在软件生存周…

excel SUBTOTAL函数使用详解

转自&#xff1a;http://www.kuqin.com/shuoit/20110524/91710.html 今天用Excel在进行业务统计时&#xff0c;遇到一个小问题&#xff0c;Google了一下&#xff0c;又学了一招。 一般人都会使用“自动筛选”功能&#xff0c;筛选完成后&#xff0c;会在表格左下角的状态栏中提…