js 实现异步队列
异步队列的实现方法
在 JavaScript 中，实现异步队列可以通过多种方式，以下是几种常见的方法：
使用 Promise 链式调用
通过 Promise 的链式调用可以确保异步任务按顺序执行。每个任务返回一个 Promise，并在前一个任务完成后触发下一个任务。
function task1() {
return new Promise(resolve => {
setTimeout(() => {
console.log('Task 1 done');
resolve();
}, 1000);
});
}
function task2() {
return new Promise(resolve => {
setTimeout(() => {
console.log('Task 2 done');
resolve();
}, 500);
});
}
task1().then(() => task2());使用 async/await
async/await 语法糖可以让异步代码看起来像同步代码，更容易理解和维护。
async function runTasks() {
await task1();
await task2();
}
runTasks();使用队列数据结构
通过数组和递归的方式实现一个异步队列，逐个执行队列中的任务。
class AsyncQueue {
constructor() {
this.queue = [];
this.isRunning = false;
}
enqueue(task) {
this.queue.push(task);
if (!this.isRunning) {
this.run();
}
}
async run() {
this.isRunning = true;
while (this.queue.length > 0) {
const task = this.queue.shift();
await task();
}
this.isRunning = false;
}
}
const queue = new AsyncQueue();
queue.enqueue(task1);
queue.enqueue(task2);使用第三方库
一些第三方库如 async 或 p-queue 提供了更强大的异步队列功能。
const PQueue = require('p-queue');
const queue = new PQueue({ concurrency: 1 });
queue.add(task1);
queue.add(task2);注意事项
- 错误处理：确保在每个异步任务中捕获错误，避免队列中断。
- 并发控制：可以通过设置并发数来控制同时执行的任务数量。
- 性能优化：避免队列过长导致内存问题，合理控制任务数量。
以上方法可以根据具体需求选择，灵活应用于实际开发场景。
