跳转到主内容
极星编程网:以代码为星,赴技术山海!

JavaScript并发控制_javascript多任务处理

JavaScript通过事件循环实现异步任务的并发控制,使用concurrentControl函数限制最大并发数,避免资源耗尽;该函数利用Promise和索引追踪任务执行,确保最多同时运行指定数量的任务,完成后汇总结果,适用于批量请求、文件上传等场景,提升应用稳定性。

JavaScript 是单线程语言,但通过事件循环和异步机制实现了看似“并发”的多任务处理。虽然不能像多线程语言那样真正并行执行代码,但可以通过合理的方式控制异步任务的并发数量,避免资源耗尽或接口请求过多导致的问题。

为什么需要并发控制在实际开发中,可能会遇到以下场景:批量上传大量文件,同时发起所有请求会占用过多带宽或触发浏览器限制爬取多个网页数据,需限制同时进行的请求数量处理大量异步任务,防止主线程阻塞或内存溢出如果不加控制,一次性启动成百上千个 Promise,可能导致系统资源紧张甚至崩溃。因此,需要一种机制来限制同时执行的任务数,这就是并发控制的核心目标。

实现一个简单的并发控制器我们可以封装一个函数,接收任务列表和最大并发数,在不超过限制的前提下按顺序执行任务。

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

”;

function concurrentControl(tasks, maxConcurrent) {return new Promise((resolve) => {let index = 0;let completed = 0;let result = [];if (tasks.length === 0) return resolve(result);function runTask() {if (index >= tasks.length) return;const currentIndex = index++;const taskPromise = tasks[currentIndex]();taskPromise.then(res => {result[currentIndex] = res;completed++;if (completed === tasks.length) {resolve(result);} else {runTask();}}).catch(err => {console.error('Task failed:', err);});}for (let i = 0; i runTask();}});}

使用方式:

const sleep = (time) => () => new Promise(r => setTimeout(r, time));const tasks = [sleep(1000),sleep(500),sleep(800),sleep(300)];concurrentControl(tasks, 2).then(() => console.log('All done'));上述代码保证最多同时运行两个任务,当前任务完成后才会拉起下一个待执行任务。

Comet AI 浏览器下载 Comet AI 浏览器,体验由 Perplexity AI 驱动的革命性上网方式。内置 AI 助手可实时总结网页、跨标签页对比信息、自动执行任务。告别繁琐操作,让 AI 成为你的浏览副驾,大幅提升研究与工作效率。支持 Windows、macOS、Android 和 iOS。

下载结合 async/await 简化逻辑利用 async 函数可以让控制流更清晰。以下是改写版本:async function concurrentControl(tasks, maxConcurrent) {const results = [];let index = 0;async function worker() {while (index const i = index++;try {const result = await tasks[i]();results[i] = result;} catch (err) {results[i] = err;}}}const workers = Array.from({ length: maxConcurrent }, () => worker());await Promise.all(workers);return results;}这个版本使用了多个“工作线程”(其实是协程)去消费任务队列,结构更简洁且易于理解。

实际应用场景举例比如从多个 URL 获取数据:const urls = ['https://api.example.com/data1','https://api.example.com/data2','https://api.example.com/data3'];const tasks = urls.map(url => () => fetch(url).then(r => r.json()));concurrentControl(tasks, 3).then(results => {console.log('所有响应:', results);});这样可以确保最多只有 3 个请求同时发出,既高效又安全。

基本上就这些。不复杂但容易忽略细节。掌握并发控制对构建健壮的异步应用很有帮助。

相关文章