TaskQueue类通过控制并发数管理异步任务执行顺序，使用Promise实现任务队列，支持按序执行、限制并发及错误处理，在爬虫、上传等场景中有效避免资源竞争。
在JavaScript中处理异步操作时，任务队列是一种常见的控制执行顺序的方式。尤其在需要按顺序执行多个异步任务、限制并发数量或实现重试机制时，一个简单的任务队列非常有用。下面是一个基于Promise的轻量级任务队列实现。
任务队列的基本结构
我们定义一个 TaskQueue 类，用于管理异步任务的添加和执行。每个任务都是一个返回 Promise 的函数（也称为“任务函数”），队列会按顺序或指定并发数执行它们。
class TaskQueue { constructor(concurrency = 1) { this.concurrency = concurrency; // 最大并发数 this.running = 0; // 当前正在运行的任务数 this.queue = []; // 任务队列 } // 添加任务 push(task) { return new Promise((resolve, reject) => { this.queue.push({ task, resolve, reject }); this.next(); }); } // 执行下一个任务 next() { while (this.running 0) { const { task, resolve, reject } = this.queue.shift(); this.running++; task() .then(resolve, reject) .finally(() => { this.running--; this.next(); // 继续执行下一个 }); } }}
使用示例
下面是一个模拟异步任务（如网络请求）的例子，使用 setTimeout 模拟延迟。
// 创建一个最多同时运行2个任务的队列const queue = new TaskQueue(2);// 生成一个异步任务function createTask(id, delay) { return () => { console.log(`任务 ${id} 开始`); return new Promise(resolve => { setTimeout(() => { console.log(`任务 ${id} 完成`); resolve(`结果-${id}`); }, delay); }); };}// 添加多个任务queue.push(createTask(1, 1000));queue.push(createTask(2, 500));queue.push(createTask(3, 800));queue.push(createTask(4, 300));// 可以监听任务完成queue.push(createTask(5, 600)).then(result => { console.log('最终任务完成:', result);});
输出将显示任务按并发限制逐步执行：1 和 2 先开始，随后是 3、4，最后是 5，但不会超过两个任务同时运行。
立即学习“Java免费学习笔记（深入）”；
扩展功能建议
这个基础版本可以进一步增强：
支持取消任务：在 push 时返回一个取消方法，从队列中移除未执行的任务。 错误重试机制：捕获失败任务并根据配置自动重试。 优先级队列：为任务添加优先级，高优先级任务先执行。 暂停/恢复：提供 pause() 和 resume() 方法控制队列运行状态。
基本上就这些。通过封装任务调度逻辑，我们可以更好地控制异步流程，避免资源竞争或过多并发请求带来的问题。这种模式在爬虫、批量上传、定时任务等场景中非常实用。
以上就是使用JavaScript实现一个简单的任务队列_js异步编程的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1534134.html
微信扫一扫 
支付宝扫一扫 
