
本文旨在提供一种有效的方法,用于在使用`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<any>>} promises - Promise 数组。
* @returns {Promise<PromiseSettledResult<any>[]>} - 与 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的返回结果对象中。这意味着每个PromiseSettledResult对象(包含status和value/reason)将额外包含一个time属性,表示该任务的完成耗时。
以下是实现此功能的辅助函数:
/**
* 封装 Promise.allSettled,并将每个 Promise 的耗时嵌入到返回结果中。
* @param {Array<Promise<any>>} promises - Promise 数组。
* @returns {Promise<Array<PromiseSettledResult<any> & { 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' }优点:
缺点:
通过对Promise.allSettled进行简单的封装和增强,我们可以轻松地获取到每个并发任务的独立完成时间。无论是通过控制台日志进行快速调试,还是将计时数据嵌入到结果中进行更深入的程序化分析,这些技术都为开发者提供了宝贵的性能洞察力。在构建高性能、响应迅速的应用程序时,理解并优化异步任务的执行效率是不可或缺的一环,而精确的计时数据正是实现这一目标的关键。
以上就是深入理解Promise.allSettled的并发任务计时与性能分析的详细内容,更多请关注php中文网其它相关文章!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号