本文旨在提供一种有效的方法，用于在使用`promise.allsettled`处理并发异步任务时，准确记录并分析每个任务的完成时间。通过自定义封装函数，我们可以将计时信息集成到`promise.allsettled`的返回结果中，从而帮助开发者识别性能瓶颈，优化任务分组策略，提升应用程序的响应效率。
异步任务并发处理与性能考量
在现代Web应用和Node.js服务中，处理多个异步操作（如API请求、数据库查询、文件读写）是常见需求。Promise.allSettled是一个强大的工具，它允许我们并发执行一组Promise，并在所有Promise都“落定”（无论成功或失败）后返回一个包含每个Promise状态和结果的数组。这对于需要等待所有任务完成才能进行下一步操作的场景非常有用，例如批量数据处理或多源数据聚合。
然而，Promise.allSettled的默认行为并不会提供每个单独Promise的执行时间。在进行性能优化时，了解每个并发任务的耗时至关重要。例如，如果您同时发起5个API调用，并发现其中某些调用显著慢于其他，那么将它们分组处理（例如，先处理快速的，再处理慢的）可能会提高用户体验或系统吞吐量。本文将介绍如何通过扩展Promise.allSettled的功能，来精确测量并获取每个并发任务的完成时间。
方案一：通过控制台日志记录任务耗时
最直接的方法是在每个Promise“落定”时记录其耗时。我们可以利用Promise.prototype.finally()方法，在每个Promise无论成功或失败时都执行一个回调函数，并在该回调中计算并打印从Promise.allSettled开始到当前Promise完成的时间差。
以下是一个实现此功能的辅助函数：
/** * 封装 Promise.allSettled，并在每个 Promise 完成时记录其耗时到控制台。 * @param {Array<Promise>} promises - Promise 数组。 * @returns {Promise<PromiseSettledResult[]>} - 与 Promise.allSettled 相同的返回结果。 */function allSettledTimedLog(promises) { const startTime = Date.now(); // 记录 Promise.allSettled 调用的起始时间 // 遍历每个 Promise，使用 .finally() 拦截其完成事件 const timedPromises = promises.map((p, index) => { return p.finally(() => { // 在 Promise 完成时计算耗时并打印 console.log(`[任务 ${index}] 完成，耗时 ${Date.now() - startTime}ms`); }); }); // 将增强后的 Promise 数组传递给 Promise.allSettled return Promise.allSettled(timedPromises);}
使用示例：
const task1 = new Promise(resolve => setTimeout(() => resolve('Task 1 Done'), 100));const task2 = new Promise((resolve, reject) => setTimeout(() => reject('Task 2 Failed'), 500));const task3 = new Promise(resolve => setTimeout(() => resolve('Task 3 Complete'), 200));allSettledTimedLog([task1, task2, task3]).then(results => { console.log('所有任务落定结果:', results);});// 预期控制台输出类似：// [任务 0] 完成，耗时 10Xms// [任务 2] 完成，耗时 20Xms// [任务 1] 完成，耗时 50Xms// 所有任务落定结果: [...]
优点：
实现简单直观。能够快速在开发过程中观察每个任务的耗时。
缺点：
计时信息仅通过控制台输出，不易于程序化地获取和进一步处理。需要手动解析日志来获取性能数据。
方案二：将计时信息嵌入到 Promise.allSettled 结果中
为了更好地利用计时数据，我们可以将每个任务的耗时直接集成到Promise.allSettled的返回结果对象中。这意味着每个PromiseSettledResult对象（包含status和value/reason）将额外包含一个time属性，表示该任务的完成耗时。
以下是实现此功能的辅助函数：
/** * 封装 Promise.allSettled，并将每个 Promise 的耗时嵌入到返回结果中。 * @param {Array<Promise>} promises - Promise 数组。 * @returns {Promise<Array<PromiseSettledResult & { time?: number }>>} - 包含耗时信息的 PromiseSettledResult 数组。 */function allSettledTimed(promises) { const startTime = Date.now(); const taskTimes = new Array(promises.length); // 用于存储每个任务的耗时 // 增强每个 Promise，使其在 finally 阶段记录耗时到 taskTimes 数组 const enhancedPromises = promises.map((p, index) => { return p.finally(() => { taskTimes[index] = Date.now() - startTime; // 记录从开始到完成的耗时 }); }); // 等待所有增强后的 Promise 落定 return Promise.allSettled(enhancedPromises).then(results => { // 将记录的耗时信息合并到 Promise.allSettled 的结果中 for (let i = 0; i < results.length; i++) { // 为每个结果对象添加 'time' 属性 results[i].time = taskTimes[i]; } return results; });}
使用示例：
const apiCall1 = new Promise(resolve => setTimeout(() => resolve({ data: 'User Info' }), 300));const apiCall2 = new Promise((resolve, reject) => setTimeout(() => reject(new Error('Auth Failed')), 600));const apiCall3 = new Promise(resolve => setTimeout(() => resolve({ data: 'Product List' }), 150));allSettledTimed([apiCall1, apiCall2, apiCall3]).then(results => { console.log('所有任务及耗时结果:', results); // 遍历结果，分析耗时 results.forEach((res, index) => { if (res.status === 'fulfilled') { console.log(`任务 ${index} 成功，耗时 ${res.time}ms，结果:`, res.value); } else { console.log(`任务 ${index} 失败，耗时 ${res.time}ms，原因:`, res.reason); } });});// 预期控制台输出类似：// 所有任务及耗时结果: [// { status: 'fulfilled', value: { data: 'User Info' }, time: 30X },// { status: 'rejected', reason: [Error: Auth Failed], time: 60X },// { status: 'fulfilled', value: { data: 'Product List' }, time: 15X }// ]// 任务 0 成功，耗时 30Xms，结果: { data: 'User Info' }// 任务 1 失败，耗时 60Xms，原因: Error: Auth Failed// 任务 2 成功，耗时 15Xms，结果: { data: 'Product List' }
优点：
计时信息直接集成到返回结果中，便于程序化访问和后续处理（如数据分析、生成报告）。结果结构清晰，一个对象包含所有相关信息。
缺点：
相对于方案一，实现略微复杂，需要一个额外的数组来临时存储计时信息。
注意事项与应用场景
输入类型限制： 上述两种实现都假定传入的promises参数是一个数组，以便使用.map()方法。如果需要支持任意可迭代对象（如Set、Map），则需要进行额外的类型转换或迭代处理。计时基准： 记录的耗时是从allSettledTimed函数被调用时开始计算的。这意味着如果您的Promises在调用allSettledTimed之前就已经启动，那么记录的耗时将是它们从allSettledTimed调用点到完成的时间，而不是它们实际的整个生命周期。对于大多数并发API调用场景，通常会在同一时间点发起所有请求并立即调用allSettledTimed，因此这种计时方式是准确且有意义的。性能分析： 获得单个任务的耗时数据后，您可以：识别慢速任务： 找出那些显著耗时更长的任务，它们可能是性能瓶颈。优化分组策略： 根据任务耗时，考虑是否将快速任务和慢速任务分开处理，以减少整体等待时间。例如，先显示快速任务的结果，再异步加载慢速任务。资源分配： 评估并发任务对系统资源（如CPU、内存、网络带宽）的影响。服务质量监控： 持续监控关键异步操作的耗时，及时发现服务降级。
总结
通过对Promise.allSettled进行简单的封装和增强，我们可以轻松地获取到每个并发任务的独立完成时间。无论是通过控制台日志进行快速调试，还是将计时数据嵌入到结果中进行更深入的程序化分析，这些技术都为开发者提供了宝贵的性能洞察力。在构建高性能、响应迅速的应用程序时，理解并优化异步任务的执行效率是不可或缺的一环，而精确的计时数据正是实现这一目标的关键。
以上就是深入理解Promise.allSettled的并发任务计时与性能分析的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1536671.html
微信扫一扫 
支付宝扫一扫 
