利用 Promise 阻塞特性实现 JavaScript 异步任务队列

作者:木棉时间:2026-10-31 13:41:06浏览:117

本文介绍如何在 JavaScript 中实现类似 Java BlockingQueue 的异步任务队列。通过利用 Promise 未 resolve 时阻塞的特性,确保任务按先进先出顺序依次执行。方案二避免了轮询带来的资源消耗和延迟问题,实现队列空闲时不占用 CPU 资源的高效处理机制。

问题

现有需求是构建一个异步任务队列,并按顺序处理队列中的所有任务。具体要求如下:

  • 在随机时间段内将异步任务添加到队列中。
  • 队列中的任务必须遵循先进先出(FIFO)的原则依次执行。
  • 任务涉及异步请求,必须等待前一个任务完全执行完毕后,才能开始执行下一个任务。

在 Java 语言中,使用 BlockingQueue 可以轻松实现上述功能。然而,JavaScript 缺乏原生的锁机制,因此实现起来相对复杂。

方案一

一个直观的思路是采用同步非阻塞方案,即每隔固定时间检测队列中是否有任务,若有则取出第一个进行处理。在此方案中,检测间隔设置为 500 毫秒,并使用 setTimeout 来模拟异步请求过程。

<body>
  <button onclick="clickMe()">点我</button>
</body>
let queue = []
let index = 0
function clickMe() {
  queue.push({name: 'click', index: index++})
}

run()
async function run() {
  while (true) {
    if (queue.length > 0) {
      let obj = queue.shift()
      let res = await request(obj.index)
      console.log('已处理事件' + res)
    } else {
      await wait(500)
      console.log('----- 队列空闲中 -----')
    }
  }
}
// 通过setTimeout模拟异步请求
function request(index) {
  return new Promise(function (resolve, reject) {
    setTimeout(() => {
      resolve(index)
    }, 1000)
  })
}
function wait(time) {
  return new Promise(function (resolve) {
    setTimeout(() => {
      resolve()
    }, time)
  })
}

问题

然而,该方案存在两个主要问题。

  • 当队列为空时,系统仍在进行循环检测,这会持续消耗系统资源。
  • 检测间隔时间的设定难以把握:若间隔时间过长,可能导致队列中的任务无法及时得到处理;若间隔时间过短,则会浪费系统资源。

那么,是否存在一种类似 Java 中 BlockingQueue 的机制,使得队列在空闲时自动阻塞,从而不消耗额外资源?

方案二

主要实现思路如下:

  • 将异步请求加入队列,当队列中的任务数量大于 0 时,开始处理队列中的任务。
  • 等待当前任务执行完毕后,再执行下一个任务。
  • 当队列中的所有任务全部处理完毕后,将 running 状态标志设置为 false。
<body>
<button onclick="clickMe()">点我</button>
</body>
// 异步请求队列
const queue = []
// 用来模拟不同的返回值
let index = 0
// 标志是否正在处理队列中的请求
let running = false

// 使用setTimeout模拟异步请求
function request(index) {
  return new Promise(function (resolve) {
    setTimeout(() => {
      resolve(index)
    }, 1000)
  })
}

// 连续点击,触发异步请求,加入任务队列
function clickMe() {
  addQueue(() => request(index++))
}

// 当队列中任务数大于0时,开始处理队列中的任务
function addQueue(item) {
  queue.push(item)
  if (queue.length > 0 && !running) {
    running = true
    process()
  }
}

function process() {
  const item = queue.shift()
  if (item) {
    item().then(res => {
      console.log('已处理事件' + res)
      process()
    })
  } else {
    running = false
  }
}

问题

结语

通过巧妙利用 Promise 在未 resolve 时会一直阻塞的特性,可以实现类似 Java BlockingQueue 的功能。这样既能保证异步任务依次执行,又能确保在队列空闲时不消耗系统资源。

到此这篇关于 JavaScript 阻塞方式实现异步任务队列的文章就介绍到这了,更多相关 JavaScript 异步队列内容请搜索本站以前的文章或继续浏览下面的相关文章希望大家以后多多支持本站!

作者最新文章