
本文探讨了如何在javascript中使用`promise.allsettled`并发执行任务时,精确测量每个独立promise的完成时间。通过两种不同的实现方式,我们可以获取任务耗时,从而深入分析异步操作的性能瓶颈,为优化api调用、批处理等场景提供数据支持,提升应用程序的响应性和效率。
在现代Web开发中,我们经常需要并发执行多个异步操作,例如同时请求多个API接口。Promise.allSettled是一个非常有用的工具,它允许我们等待所有Promise完成(无论成功或失败),并返回每个Promise的结果状态。然而,在某些场景下,我们不仅关心所有任务是否完成,更希望了解每个任务具体耗时多久。这对于性能分析至关重要,例如,当我们需要判断是否值得将一组API请求拆分为多个批次,以优先处理那些快速完成的任务时。
为什么需要对Promise进行计时?
对并发执行的Promise进行单独计时,可以帮助我们:
- 识别性能瓶颈: 找出耗时最长的异步操作。
- 优化资源分配: 根据任务耗时特点,调整并发策略,例如将耗时相近或相互依赖的任务分组。
- 用户体验分析: 了解不同操作对用户等待时间的影响。
- 服务质量监控: 持续跟踪外部服务或内部模块的响应时间。
实现Promise.allSettled的计时功能
以下将介绍两种在Promise.allSettled中集成任务计时的方法。
方法一:通过控制台日志输出计时结果
这种方法简单直接,它在每个Promise完成时,立即通过控制台输出其耗时。计时结果不会作为Promise.allSettled的最终返回值的一部分。
立即学习“Java免费学习笔记(深入)”;
/** * 包装Promise数组,使其在完成时记录并输出耗时。 * * @param {Array<Promise>} promises 待执行的Promise数组。 * @returns {Promise<Array<Object>>} Promise.allSettled的原始结果。 */ function allSettledTimedAndLogged(promises) { const start = date.now(); // 记录整个批次开始时间 return Promise.allSettled(promises.map((p, index) => { // 使用.finally()确保无论Promise成功或失败,都能记录时间 return p.finally(() => { console.log(`[任务 ${index}] 完成,耗时 ${Date.now() - start}ms`); }); })); }
示例用法:
const task1 = new Promise(resolve => setTimeout(() => resolve('Task 1 Done'), 1000)); const task2 = new Promise((_, reject) => setTimeout(() => reject('Task 2 Failed'), 500)); const task3 = new Promise(resolve => setTimeout(() => resolve('Task 3 Done'), 1500)); console.log('开始执行并发任务...'); allSettledTimedAndLogged([task1, task2, task3]) .then(results => { console.log('所有任务完成,Promise.allSettled结果:', results); }); // 预期控制台输出(顺序可能因Promise完成时间而异): // 开始执行并发任务... // [任务 1] 完成,耗时 ~1000ms // [任务 0] 完成,耗时 ~500ms (如果任务2先完成) // [任务 2] 完成,耗时 ~1500ms // 所有任务完成,Promise.allSettled结果: [...]
注意事项:
- 此方法记录的是相对于整个批次开始时间的耗时,而非每个Promise独立启动的耗时。在并发场景下,这通常是我们更关心的指标。
- 计时信息直接打印到控制台,不方便进行后续的程序化处理。
方法二:将计时结果嵌入到Promise.allSettled的返回数据中
如果需要将每个Promise的耗时作为其结果的一部分返回,以便后续处理或分析,可以采用以下方法。这通过在Promise.allSettled的结果处理阶段,将预先记录的耗时数据合并进去实现。
/** * 包装Promise数组,使其在完成时记录耗时,并将计时结果嵌入到Promise.allSettled的返回数据中。 * * @param {Array<Promise>} promises 待执行的Promise数组。 * @returns {Promise<Array<Object>>} 包含每个Promise状态和耗时的结果数组。 */ function allSettledTimed(promises) { const start = Date.now(); // 记录整个批次开始时间 const times = new Array(promises.length); // 用于存储每个Promise的耗时 // 包装每个Promise,使其在完成时记录耗时 const wrappedPromises = promises.map((p, index) => { return p.finally(() => { times[index] = Date.now() - start; // 记录相对于批次开始时间的耗时 }); }); // 等待所有Promise完成,然后将计时数据合并到结果中 return Promise.allSettled(wrappedPromises).then(results => { // 遍历结果数组,将对应的耗时添加到每个结果对象中 for (let i = 0; i < results.length; i++) { results[i].time = times[i]; // 添加自定义的'time'属性 } return results; }); }
示例用法:
const apiCall1 = new Promise(resolve => setTimeout(() => resolve({ id: 1, data: 'User A' }), 1200)); const apiCall2 = new Promise((_, reject) => setTimeout(() => reject(new Error('Network Error')), 600)); const apiCall3 = new Promise(resolve => setTimeout(() => resolve({ id: 3, data: 'Product X' }), 800)); console.log('开始执行带计时的并发api调用...'); allSettledTimed([apiCall1, apiCall2, apiCall3]) .then(results => { console.log('所有API调用完成,结果(含计时):', results); // 进一步分析结果 results.forEach((res, index) => { if (res.status === 'fulfilled') { console.log(`API ${index + 1} 成功,耗时 ${res.time}ms,值:`, res.value); } else { console.log(`API ${index + 1} 失败,耗时 ${res.time}ms,原因:`, res.reason.message); } }); // 查找最慢的任务 const slowestTask = results.reduce((prev, current) => (prev.time > current.time ? prev : current)); console.log('最慢的任务耗时:', slowestTask.time, 'ms'); }); // 预期控制台输出: // 开始执行带计时的并发API调用... // 所有API调用完成,结果(含计时): [ // { status: 'fulfilled', value: { id: 1, data: 'User A' }, time: ~1200 }, // { status: 'rejected', reason: Error: Network Error, time: ~600 }, // { status: 'fulfilled', value: { id: 3, data: 'Product X' }, time: ~800 } // ] // API 1 成功,耗时 ~1200ms,值: { id: 1, data: 'User A' } // API 2 失败,耗时 ~600ms,原因: Network Error // API 3 成功,耗时 ~800ms,值: { id: 3, data: 'Product X' } // 最慢的任务耗时: ~1200 ms
注意事项:
- 此实现假设传入的是一个数组(以便使用.map())。如果需要支持任意可迭代对象,则需要额外的代码进行转换。
- Date.now()提供了毫秒级的精度,对于大多数性能分析场景已经足够。对于需要更高精度的场景,可以考虑使用performance.now()(但它返回的是高精度时间戳,通常用于测量网页加载或脚本执行时间)。
- 这种方法返回的结果结构更丰富,便于后续的自动化处理和报告生成。
总结
通过上述两种方法,我们可以在使用Promise.allSettled进行并发任务管理时,有效地测量每个任务的执行时间。方法一适用于快速调试和日志记录,而方法二则提供了更结构化的数据,便于进行深入的性能分析和程序化决策。选择哪种方法取决于具体的应用场景和对计时数据处理的需求。掌握这些技术,将有助于开发者更好地理解和优化异步javaScript应用的性能表现。