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

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

如何实现javascript并发控制_多个异步任务怎样调度?-第1张图片-佛山资讯网

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 = []
  }
<p>push(fn) {
return new Promise((resolve, reject) => {
this.taskQueue.push({ fn, resolve, reject })
this.#run()
})
}</p><h1>run() {</h1><pre class='brush:php;toolbar:false;'>if (this.running >= this.max || this.taskQueue.length === 0) return
this.running++
const { fn, resolve, reject } = this.taskQueue.shift()
fn().then(resolve).catch(reject).finally(() => {
  this.running--
  this.#run() // 尝试调度下一个
})

登录后复制

} }

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

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

标签: javascript es6 java js json 异步任务

发布评论 0条评论)

还木有评论哦,快来抢沙发吧~