如何控制nodejs的线程数
时间:2022-07-22
本文章向大家介绍如何控制nodejs的线程数,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
nodejs提供了线程能力,但是我们不能一味地开启线程,需要控制数据,本文分享如何去控制数量。
1 设计思路 设计的思路比较简单,就是在用户和work_threads模块之前加一层,如果用户直接调用work_threads模块,那就可以创建任意数量的线程,控制就无从说起。通过加一层,可以缓存用户提交的任务,等到有线程退出(有任务处理完)的时候,再开启新的线程去处理缓存的任务。
2 具体实现 2.1 配置的实现 定义一些配置,比如最多能创建的线程数。使用Proxy,劫持一下对象,可以做一些事情,不过目前没有。
// 线程池配置,使用Proxy,可以劫持属性的读写,做点事情
const CONFIG = new Proxy({
MAX_THREAD: 3,
}, {
get(obj, key) {
return obj[key];
},
set(obj, key, value) {
obj[key] = value;
return true;
}
})
2.2 控制逻辑的实现
2.2.1 构造函数 线程池记录当前的线程数和缓存的任务队列。
constructor() {
// 任务队列
this._workQueue = [];
// 当前线程数
this._count = 0;
}
2.2.2 新建一个线程
_newThread(...rest) {
// todo 新建失败处理
const worker = new Worker(...rest);
// 线程数加一
this._count++;
// 退出后,如果有缓存的任务,则新建线程处理
worker.on('exit', () => {
this._count--;
// 有名额了并且有任务在等待
if (this._workQueue.length) {
const {
resolve,
reject,
params,
} = this._workQueue.shift();
// 开启线程,并且通知用户
resolve(this._newThread(...params));
}
});
return worker;
}
2.2.3 提交任务给线程池
// 给线程池提交一个任务
submit(...rest) {
return new Promise((resolve, reject) => {
// 还没有达到阈值,则新建线程,否则缓存起来
if (this._count < CONFIG.MAX_THREAD) {
resolve(this._newThread(...rest));
} else {
this._workQueue.push({resolve, reject, params: rest});
}
});
}
}
思想很简单,根据配置,最多创建n个线程,如果任务太多的话,就缓存起来,等待有线程退出的时候,再新建一个线程处理缓存起来的任务。API使用Promise方式。这样可以实现等待操作。等到创建线程的时候可以通知用户。而且用户使用的时候,几乎是透明的,没有太多额外的成本,因为只是做了一些封装,几乎是透传nodejs的线程功能。最后提供多种方式调用,包括一个默认的控制器、创建多个控制器。
const defaultThreadGate = new ThreadGate();
module.exports = {
ThreadGate,
defaultThreadGate,
submit: (...rest) => {
return defaultThreadGate.submit(...rest);
},
CONFIG,
}
- weblogic启动失败:Could not obtain the localhost address 解决办法
- 如何理解云计算?很简单,就像吃货想吃披萨了……
- .NET 2.0 中使用Active Directory 应用程序模式 (ADAM)
- struts2: 通过流输出实现exce导出
- Google的数据交换协议:GData (Google Data APIs Protocol)
- C# 内部类
- 四字母.com域名均以五位数结拍
- mybatis 3.2.7 与 spring mvc 3.x、logback整合
- spring 3.2.x + struts2 + mybatis 3.x + logback 整合配置
- struts2使用Convention Plugin在weblogic上以war包部署时,找不到Action的解决办法
- 使用xfce4桌面系统
- 号外!号外!Python纳入高考内容了!人工智能时代就要来临了!
- 高颜值!域名5h.net和jb.cc纷纷易主
- 认识ASP.NET 5项目结构和项目文件xproj
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法