
本文深入探讨如何在javascript中使用promise.allsettled处理并发异步任务时,精确测量每个独立promise的执行时间。通过提供两种实用方法,读者将学习如何记录并获取每个任务从启动到完成的耗时,无论是通过日志输出还是将时间数据嵌入到最终结果中,这对于性能分析、识别瓶颈以及优化用户体验至关重要。
理解Promise.allSettled与性能分析需求
在现代Web开发和Node.js应用中,处理并发异步操作是常见的场景。Promise.allSettled是一个强大的工具,它允许我们等待一组Promise全部完成(无论成功或失败),并返回每个Promise的最终状态和值(或原因)。然而,Promise.allSettled本身并不提供每个独立Promise的执行时间信息。
在某些情况下,了解每个并发任务的具体耗时至关重要。例如,当您同时向多个远程服务发起API请求时,如果其中一些请求耗时过长,可能会影响整体用户体验。通过测量每个请求的独立耗时,您可以识别性能瓶颈,甚至考虑优化策略,例如将快速请求和慢速请求分组处理,以尽早响应部分结果。
本文将介绍两种技术,用于在Promise.allSettled的上下文中,有效地测量和获取每个Promise的执行时间。
方法一:通过日志记录独立Promise的耗时
这种方法通过在每个Promise完成时立即记录其耗时,并将结果输出到控制台。它适用于快速调试和概览每个任务的执行情况,而无需修改Promise.allSettled的最终返回结构。
实现原理
核心思想是利用Promise.prototype.finally()方法。finally()回调函数无论Promise是成功(fulfilled)还是失败(rejected)都会执行,这使得它成为记录完成时间的理想位置。我们可以在finally回调中计算从任务开始到当前时间的时间差。
示例代码
/**
* 包装Promise数组,使其在完成时记录各自的执行时间。
*
* @param {Array>} promises 待处理的Promise数组。
* @returns {Promise[]>} Promise.allSettled的结果。
*/
function allSettledTimedLog(promises) {
const startTime = Date.now(); // 记录整个批次开始的时间
return Promise.allSettled(promises.map((p, index) => {
return p.finally(() => {
// 在每个Promise完成时,计算并记录其耗时
console.log(`[任务 ${index}] 完成,耗时: ${Date.now() - startTime}ms`);
});
}));
}
// 模拟异步任务
const task1 = new Promise(resolve => setTimeout(() => resolve('Data from Task 1'), 100));
const task2 = new Promise(resolve => setTimeout(() => resolve('Data from Task 2'), 300));
const task3 = new Promise((resolve, reject) => setTimeout(() => reject(new Error('Task 3 Failed')), 200));
console.log("开始执行 Promise.allSettledTimedLog...");
allSettledTimedLog([task1, task2, task3]).then(results => {
console.log("所有任务完成,Promise.allSettled 结果:", results);
}); 代码解析
- startTime = Date.now();: 在函数开始时记录一个基准时间。所有任务的耗时都将相对于这个时间点计算。
- promises.map((p, index) => { ... });: 遍历原始的Promise数组。
- p.finally(() => { ... });: 为每个原始Promise添加一个finally回调。当该Promise完成时,无论成功或失败,此回调都会执行。
- console.log(...);: 在finally回调中,Date.now() - startTime计算出当前Promise从批次开始到完成所经过的时间,并将其打印到控制台。
- Promise.allSettled(...): 将所有被finally包装过的Promise传递给Promise.allSettled,确保等待所有任务完成。
注意事项: 这种方法记录的是每个Promise相对于整个批次开始时间的完成时间,而不是其纯粹的独立执行时间(从其自身开始到自身结束)。但对于分析并发任务的相对速度和瓶颈识别,这通常已足够。
方法二:将耗时信息嵌入到Promise.allSettled的结果中
如果需要以编程方式访问每个任务的耗时数据,而不仅仅是打印到控制台,可以将时间信息直接集成到Promise.allSettled返回的结果对象中。
实现原理
与方法一类似,我们仍然使用finally()来捕获每个Promise的完成时间。但这次,我们不会立即打印,而是将时间存储在一个外部数组中。一旦Promise.allSettled本身完成,我们再遍历其结果,并将之前存储的时间数据注入到对应的结果对象中。
示例代码
/**
* 包装Promise数组,使其在完成时记录各自的执行时间,并将时间嵌入到结果中。
*
* @param {Array>} promises 待处理的Promise数组。
* @returns {Promise & { time?: number }>>} 包含耗时信息的Promise.allSettled结果。
*/
function allSettledTimed(promises) {
const startTime = Date.now();
// 用于存储每个Promise的耗时
const taskTimes = new Array(promises.length);
// 1. 包装Promise,并在finally中记录完成时间到taskTimes数组
const wrappedPromises = promises.map((p, index) => {
return p.finally(() => {
taskTimes[index] = Date.now() - startTime;
});
});
// 2. 等待所有包装后的Promise完成,然后处理结果
return Promise.allSettled(wrappedPromises).then(results => {
// 3. 将记录的耗时信息合并到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('API 1 Success'), 150));
const apiCall2 = new Promise(resolve => setTimeout(() => resolve('API 2 Success'), 400));
const apiCall3 = new Promise(resolve => setTimeout(() => resolve('API 3 Success'), 250));
const apiCall4 = new Promise((resolve, reject) => setTimeout(() => reject(new Error('API 4 Failed')), 500));
console.log("开始执行 Promise.allSettledTimed...");
allSettledTimed([apiCall1, apiCall2, apiCall3, apiCall4]).then(resultsWithTime => {
console.log("所有API调用完成,结果(包含耗时信息):");
resultsWithTime.forEach((result, index) => {
console.log(`任务 ${index}: 状态=${result.status}, 耗时=${result.time}ms`);
if (result.status === 'fulfilled') {
console.log(` 值: ${result.value}`);
} else {
console.log(` 原因: ${result.reason.message}`);
}
});
}); 代码解析
- startTime 和 taskTimes: 同样记录批次开始时间,并初始化一个数组taskTimes来存储每个Promise的耗时。
- promises.map((p, index) => { ... });: 为每个原始Promise添加finally回调,但这次,finally不再打印,而是将计算出的耗时赋值给taskTimes[index]。
- Promise.allSettled(wrappedPromises): 等待所有这些被finally包装过的Promise完成。
- .then(results => { ... });: 当Promise.allSettled返回其标准结果后,我们进入这个then回调。
- for (let i = 0; i
- return results;: 返回修改后的结果数组,其中包含了每个任务的耗时信息。
注意事项:
- 此实现假设传入的是一个可使用.map()方法的数组。如果需要处理任意可迭代对象,则需要稍作修改(例如,先将其转换为数组)。
- Date.now()提供了毫秒级的时间精度。对于大多数性能分析场景而言,这已足够。如果需要更高精度(例如微秒级),可以考虑使用performance.now()。
- finally回调确保了无论Promise最终是成功还是失败,我们都能捕获到其完成时间。
总结
通过上述两种方法,您可以在使用Promise.allSettled管理并发异步任务时,有效地追踪和分析每个独立任务的执行耗时。方法一适用于快速日志输出和调试,而方法二则提供了更结构化的数据,便于后续的编程处理和自动化分析。这些技术对于识别系统中的性能瓶颈、优化资源分配以及提升用户体验具有重要的实践意义。










