如何实现javascript并发控制_多个异步任务怎样调度?

JavaScript并发控制通过Promise+队列+计数器实现,用固定槽位限制同时执行任务数(如3个),新任务入队等待空闲,running计数器跟踪运行中任务,完成即释放槽位并调度下一个。

如何实现javascript并发控制_多个异步任务怎样调度?

JavaScript 并发控制的核心是限制同时执行的异步任务数量,避免资源耗尽或接口限流报错。不靠轮询、不靠 setTimeout 模拟,而是用 Promise 配合队列 + 计数器来稳稳调度。

用固定数量的“执行槽位”管理任务

本质是维护一个最大并发数(比如 3),只允许最多 3 个 Promise 同时处于 pending 状态。新任务来了不立刻执行,而是进队列等待空闲槽位。

维护一个 running 计数器,记录当前正在执行的任务数维护一个 taskQueue 数组,存放待执行的 Promise 创建函数(不是 Promise 本身)每次有任务完成,就递减 running,并从队列里取一个新任务启动

封装一个通用的并发控制器类

下面是一个轻量实用的实现(ES6 Class):

class ConcurrencyController {  constructor(max) {    this.max = max    this.running = 0    this.taskQueue = []  }

push(fn) {return new Promise((resolve, reject) => {this.taskQueue.push({ fn, resolve, reject })this.#run()})}

run() {

if (this.running >= this.max || this.taskQueue.length === 0) returnthis.running++const { fn, resolve, reject } = this.taskQueue.shift()fn().then(resolve).catch(reject).finally(() => {  this.running--  this.#run() // 尝试调度下一个})

}}

使用示例:同时最多请求 2 个接口

立即学习“Java免费学习笔记(深入)”;

const controller = new ConcurrencyController(2)

const tasks = urls.map(url => () => fetch(url).then(r => r.json()))

Promise.all(tasks.map(task => controller.push(task))).then(results => console.log(results))

注意错误处理与任务取消(可选增强)

原生 Promise 不支持取消,但你可以加一层包装:

在 push 时返回一个带 abort 方法的对象(内部用 AbortController)队列中的任务若被取消,跳过执行并直接 rejectrunning 计数器只对真正 start 的任务增减,避免误判

不过多数业务场景只需基础调度——保证不超并发、结果顺序无关、失败不影响其他任务即可。

基本上就这些。关键不是写多 fancy 的代码,而是想清楚:谁排队、谁占位、谁释放、谁接替。

以上就是如何实现javascript并发控制_多个异步任务怎样调度?的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1544359.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月21日 15:49:53
下一篇 2025年12月21日 15:50:03

相关推荐

发表回复

登录后才能评论
关注微信