集群

import {Util} from "../modules/core/utils";const Queue = require('bull'),cluster = require('cluster');const numWorkers = 8;const queue = new Queue("nike", {redis: {port: 6379, host: '192.168.10.167', password: null},prefix: 'nike_',defaultJobOptions: {attempts: 1,removeOnComplete: true,backoff: false,delay: 0,},limiter: {max: 200000,duration: 1000,},settings: {maxStalledCount: 1,guardInterval: 1,//重新调度延迟retryProcessDelay: 500,// delay before processing next job in case of internal error.// drainDelay: 50000,},
});
let count = 0;
if (cluster.isMaster) {for (let i = 0; i < numWorkers; i++) {cluster.fork();}cluster.on('online', async (worker) => {for (let i = 0; i < 100; i++) {await queue.add({data: 1});console.log(await queue.count())}});//工作退出了cluster.on('exit', function (worker, code, signal) {console.log('worker ' + worker.process.pid + ' died');});
} else {queue.process(async (job) => {count++;await Util.Coder.sleep(2);console.log("Job done by worker", cluster.worker.id, job.id, count);return Promise.resolve();});
}

nodejs 任务调度bull 测试解析相关推荐

  1. 【Android 异步操作】线程池 ( 线程池作用 | 线程池种类 | 线程池工作机制 | 线程池任务调度源码解析 )

    文章目录 一.线程池作用 二.线程池种类 三.线程池工作机制 四.线程池任务调度源码解析 一.线程池作用 线程池作用 : ① 避免创建线程 : 避免每次使用线程时 , 都需要 创建线程对象 ; ② 统 ...

  2. 天龙八部荣耀版体验服服务器未响应,《天龙八部荣耀版》创新竖版手游官网-合区来了!体验服合区测试解析...

    亲爱的少侠: 为了增加江湖人气,为众位少侠带来更好的游戏体验,<天龙八部荣耀版>的合服即将开始啦.12月16日游戏率先在体验服服务器进行合服操作测试,让我们一起来看看吧. 此次体验服1区和 ...

  3. 使用Nodejs+Protractor搭建测试环境

    Protractor是一个end-to-end的测试框架,从网络上得到的答案是Protractor是作为Angular JS应用程序的测试框架.它的构建基于Selenium WebDriver之上,且 ...

  4. JS相关环境搭建:Nodejs、karma测试框架、jsDuck、Express

    第一章:压缩js(nodejs,uglify) 第一步:安装nodejs环境 直接下载http://www.nodejs.org/download/ 下载完成后直接下一步下一步即可,完了我们就具有no ...

  5. 2021年江苏省职业院校技能大赛中职 网络信息安全赛项试卷--web安全渗透测试解析

    2021年江苏省职业院校技能大赛中职 网络信息安全赛项web安全渗透测试 2021年江苏省web安全渗透测试任务书 2021年江苏省web安全渗透测试任务书解析 如果有不懂得地方可以私信博主,欢迎交流 ...

  6. 2023年中职组网络安全竞赛——综合渗透测试解析

    综合渗透测试 题目如下: PS:需求环境可私信博主,求个三连吧! 解析如下: 通过本地PC中的渗透测试平台KALI2020对服务器场景进行渗透攻击,获取到RSYNC服务所开放的端口,将RSYNC服务开 ...

  7. NodeJs初学者经典入门解析

     Node.js 是一个基于谷歌浏览器JavaScript执行环境建立的一个平台,让JavaScript可以脱离客户端浏览器运行,让 JavaScript具有服务器语言的能力.我们可以使用Node ...

  8. 【软件测试】8年资深测试解析,软件测试行业情报,风风雨雨......

    目录:导读 前言 一.Python编程入门到精通 二.接口自动化项目实战 三.Web自动化项目实战 四.App自动化项目实战 五.一线大厂简历 六.测试开发DevOps体系 七.常用自动化测试工具 八 ...

  9. GL benchmark测试解析

    [转自:http://tieba.baidu.com/p/1966590296?from=prin] 1. 都是测GPU的 2. 恩 确实比较奇怪,但也不奇怪 http://www.anandtech ...

  10. android软件路况软件,随身路况利器 安卓专用APP测试解析

    上班堵.下班堵.晴天堵.雨天堵,能拥有一辆汽车也算是白领身份的一种象征,但是无论是摇号也好.限行也罢,一出行就要堵上一会是真让人烦闷.所以准确的路况信息现在成为了出行的防堵利器.以往的产品借助TMC广 ...

最新文章

  1. Android之平台架构
  2. [Oracle] oracle统计信息
  3. java jar 打包命令行_Java程序命令行打包Jar
  4. Vuex与登录状态保存
  5. The Linux SG_IO ioctl in the 2.6 series
  6. RISC与CISC比较
  7. linux mysql 停止,linux 里 重启 和停止 mysql的原理
  8. Oracle入门(七)之表空间
  9. 1.three.js世界的4大要素
  10. python rpc webservice_关于RPC、HTTP、WebService的区别
  11. Python《爬取IPhone各式壁纸》
  12. win 10配置安装iis
  13. 【312天】我爱刷题系列071(2017.12.14)
  14. jsp引用带参数的js文件,例如 script src=a.js?ctxpath=${base
  15. 计算机音乐叫什么名字,电脑开机那段美妙的音乐叫什么名字?
  16. JSP的3种方式实现radio ,checkBox,select的默认选择值
  17. android 网易音乐sdk,Netease Music SDK 开发文档
  18. 数据库实验报告-实验一:SQL语言
  19. 分布式光伏风电新能源电站并网必备须知:正反向隔离装置组网-也适用于微网储能虚拟电厂
  20. 湖南省计算机等级考试(二级)题库 第六部分

热门文章

  1. 麦达数字SaaS布局再落子9300万投资赢销通
  2. Nginx 多重判断
  3. [转]MTK android 下载及启动过程
  4. 改进后的日志类CLogger
  5. Windows 7 通过无线网卡,模拟Wifi,实现手机,电脑等无线设备共享上网
  6. 4.从Paxos到Zookeeper分布式一致性原理与实践--- Zookeeper 与 Paxos
  7. 14.Linux/Unix 系统编程手册(上) -- 文件系统
  8. 21.TCP/IP 详解卷1 --- TCP 的超时与重传
  9. 31. HTTP 与 HTTPS 区别
  10. 124. PHP 性能分析