本文深入探讨如何在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<Promise<any>>} promises 待处理的Promise数组。
* @returns {Promise<PromiseSettledResult<any>[]>} 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<Promise<any>>} promises 待处理的Promise数组。
* @returns {Promise<Array<PromiseSettledResult<any> & { 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 < results.length; i++) { results[i].time = taskTimes[i]; }: 遍历Promise.allSettled返回的results数组，将之前存储在taskTimes中的对应耗时数据添加到每个结果对象的time属性上。
- return results;: 返回修改后的结果数组，其中包含了每个任务的耗时信息。
注意事项：
- 此实现假设传入的是一个可使用.map()方法的数组。如果需要处理任意可迭代对象，则需要稍作修改（例如，先将其转换为数组）。
- Date.now()提供了毫秒级的时间精度。对于大多数性能分析场景而言，这已足够。如果需要更高精度（例如微秒级），可以考虑使用performance.now()。
- finally回调确保了无论Promise最终是成功还是失败，我们都能捕获到其完成时间。
总结
通过上述两种方法，您可以在使用Promise.allSettled管理并发异步任务时，有效地追踪和分析每个独立任务的执行耗时。方法一适用于快速日志输出和调试，而方法二则提供了更结构化的数据，便于后续的编程处理和自动化分析。这些技术对于识别系统中的性能瓶颈、优化资源分配以及提升用户体验具有重要的实践意义。
