集群

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. linux哪个版本支持多线程,关于Linux操作系统的叙述错误的是()A、Linux是多用户、多任务、支持多线程的操作系统B、Linux的源...
  2. 常用排序算法对比(时间复杂度、稳定性)
  3. 计算机书籍-R语言机器学习预测分析实战
  4. 【错误记录】前台进程报错 ( Bad notification for startForeground invalid channel for service notification )
  5. wxWidgets:wxSashWindow类用法
  6. asp.net中生命周期的浅析
  7. ×××技术详解(全)
  8. (转)Spring Boot 2 (六):使用 Docker 部署 Spring Boot 开源软件云收藏
  9. DPDK 锁:ticketlock和mcslock
  10. 关于PHP页面显示乱码问题的解决
  11. c语言 有关文件读/写函数 详解
  12. matlab颜色识别提取,matlab实现图像颜色特征提取
  13. IT计算机行业都有哪些证可以考
  14. 浅谈利用javascript实现gb2312编码。
  15. FFmpeg指令(./configure 其他)
  16. Winserver2016安装Exchange2016总结(一堆坑)
  17. 商务礼仪的6大准则(转)
  18. 文档级机器翻译综述:A Survey on Document-level Machine Translation: Methods and Evaluation
  19. CSS-3D酷炫柱状图
  20. AXI总线学习(AXI34)

热门文章

  1. iOS开发规范篇:清晰的初始化方法
  2. Hexo + Github搭建自己的博客
  3. 基础才是重中之重~LazyInitializer.EnsureInitialized对属性实现化的性能优化
  4. 从托管映像创建 VM
  5. SG 函数初步 HDU 1536 amp;amp; HDU 1944
  6. 为什么一般都使用 List list = new ArrayList() ,而不用 ArrayList alist = new ArrayList()呢?...
  7. 树莓派 之 动态DNS(DNSPod)
  8. 完美配置Tomcat的HTTPS
  9. 忘记密码后恢复思科设备密码的方案
  10. [转]ASP.NET MVC中你必须知道的13个扩展点