使用 promise.all() 结合数组的 reduce() 方法可以实现异步操作的并行归约。核心做法是：在 reduce 的回调中，将前一步的结果（即上一个 promise）与当前元素的处理逻辑组合成一个新的 promise，并通过 .then() 链式传递。由于 reduce 本身是同步遍历，所有异步任务会在初始化阶段被同时触发并进入并发执行状态，从而实现并行处理。
如何构建初始 Promise 以启动归约链
必须为 reduce 提供一个明确的初始值，且该初始值必须是一个已解决的 Promise。如果数组为空或需要从零开始累加，可以使用 Promise.resolve(0) 作为初始值。这样做确保了 reduce 的第一次回调接收到的第一个参数是一个 Promise 对象，从而能够立即调用 .then() 来挂载后续的异步操作。
const data = [1, 2, 3];
async function parallelReduce(arr) {
const result = await arr.reduce(async (promiseChain, currentVal) => {
// 等待前一个异步操作完成
const prevResult = await promiseChain;
// 执行当前元素的异步处理
// 这里模拟一个异步计算
const newResult = await processAsync(currentVal, prevResult);
return newResult;
}, Promise.resolve(0)); // 初始值为 resolved Promise
return result;
}
function processAsync(val, acc) {
return new Promise(resolve => {
setTimeout(() => resolve(acc + val), 100);
});
}
parallelReduce(data).then(console.log); // 输出 6
上述代码中，Promise.resolve(0) 启动了归约链。当 reduce 第一次迭代时，promiseChain 就是那个初始 Promise。通过 await promiseChain，我们确保在处理 data[0] 之前，初始状态已经就绪。随后，processAsync 被调用，它返回一个新的 Promise，这个新 Promise 又成为了下一次迭代的 promiseChain。这种模式使得每个步骤都依赖于前一步的结果，但所有步骤的“发起”动作在循环中是连续发生的，因此它们并行运行。
如何处理中间结果的状态传递
在并行归约中，关键在于理解 reduce 回调返回的值会被传递给下一次迭代。如果回调返回的是一个普通值，下一次迭代的 promiseChain 就会变成那个普通值，导致 await promiseChain 直接解析，但这通常不是我们想要的，因为我们希望保持异步链的连续性。因此，每次回调必须返回一个 Promise。在这个例子中，processAsync 返回的 Promise 既代表了当前步骤的计算结果，也作为下一个步骤的输入源。这种设计允许我们在不阻塞主线程的情况下，按顺序消费并行任务的结果。
// 对比串行与并行的关键差异
// 串行：每一步必须等上一步完全结束才发起下一步
// 并行：所有步骤的发起几乎同时，但结果按序聚合
const tasks = [
() => fetch('/api/1'),
() => fetch('/api/2'),
() => fetch('/api/3')
];
// 并行获取所有数据
const allData = await Promise.all(tasks.map(fn => fn()));
// 并行归约：假设我们需要对每个API响应进行累积计算
const reduced = await tasks.reduce(async (accPromise, taskFn) => {
const acc = await accPromise;
const response = await taskFn();
// 假设我们要累加响应中的某个字段
return acc + (response.data || 0);
}, Promise.resolve(0));
在第二个代码示例中，tasks.map(fn => fn()) 展示了纯并行的概念，而 reduce 版本则展示了如何在并行的基础上进行有序归约。注意，taskFn() 是在 await accPromise 之后调用的，这意味着虽然网络请求是并发的，但结果的合并是按数组顺序进行的。如果不需要依赖前一个结果，可以直接使用 Promise.all；如果需要依赖，则必须使用这种基于 reduce 的异步链模式。
当初始值为非 Promise 时会发生什么
如果在 reduce 中传入一个非 Promise 的初始值，例如数字 0，第一次迭代时 promiseChain 将是 0。此时 await 0 会立即解析为 0，这看起来没问题。但是，如果回调函数返回的是一个 Promise，那么第二次迭代时 promiseChain 就变成了一个 Promise 对象。从第三次迭代开始，一切正常。然而，这种混合类型会导致代码行为不一致，且在空数组情况下，reduce 会直接返回初始值 0，而不是 Promise，这可能导致调用者忘记使用 await 或 .then() 来处理结果。因此，始终使用 Promise.resolve(initialValue) 是最安全的做法，它能保证整个归约过程始终处于异步上下文中。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
