forEach
和 async/await
的這個(gè)組合,就像一對(duì)貌合神離的“情侶”,看起來般配,實(shí)則互相“背叛”。這個(gè)坑,我結(jié)結(jié)實(shí)實(shí)地踩過,而且不止一次。
故事的開始:一個(gè)看似無害的需求
想象一下,接到一個(gè)需求:批量更新一組用戶的狀態(tài)。后端提供了一個(gè)接口 updateUser(userId)
,它是一個(gè)返回 Promise 的異步函數(shù)。第一反應(yīng)可能就是這樣寫:
const userIds = [1, 2, 3, 4, 5];
async function updateUserStatus(id) {
console.log(`開始更新用戶 ${id}...`);
// 模擬一個(gè)需要 1 秒的網(wǎng)絡(luò)請(qǐng)求
await new Promise(resolve => setTimeout(resolve, 1000));
console.log(`? 用戶 ${id} 更新成功!`);
return { success: true };
}
async function batchUpdateUsers(ids) {
console.log("--- 開始批量更新 ---");
ids.forEach(async (id) => {
await updateUserStatus(id);
});
console.log("--- 所有用戶更新完畢!---"); // ?? 問題的根源在這里!
}
batchUpdateUsers(userIds);
運(yùn)行這段代碼,控制臺(tái)輸出了什么?不是期望的按順序等待,而是這樣的結(jié)果:
看到了嗎?“所有用戶更新完畢!”
這句話幾乎是立即打印出來的,它根本沒有“等待”任何 updateUserStatus
函數(shù)的完成。
問題剖析:forEach
到底干了什么?
forEach
被設(shè)計(jì)為同步迭代器。它的工作很簡(jiǎn)單:遍歷數(shù)組中的每個(gè)元素,并為每個(gè)元素同步地調(diào)用你提供的回調(diào)函數(shù)。它不關(guān)心你的回調(diào)函數(shù)是同步的還是異步的,也不關(guān)心它返回什么。
換句話說,forEach
的內(nèi)心獨(dú)白是:
“我的任務(wù)就是觸發(fā),觸發(fā),再觸發(fā)。至于你傳進(jìn)來的那個(gè) async
函數(shù)什么時(shí)候執(zhí)行完?抱歉,那不歸我管,我不會(huì)等它的?!?/span>
正確的姿勢(shì):如何真正地“等待”?
既然 forEach
不行,那我們?cè)撚檬裁??答案是使用那些“懂?Promise 的循環(huán)方式。
方案一:老實(shí)人 for...of
循環(huán)(順序執(zhí)行)
如果我們需要按順序、一個(gè)接一個(gè)地執(zhí)行異步操作,for...of
循環(huán)是你的最佳選擇。它是 async/await
的天作之合。
async function batchUpdateUsersInOrder(ids) {
console.log("--- 開始批量更新 (順序執(zhí)行) ---");
for (const id of ids) {
// 這里的 await 會(huì)實(shí)實(shí)在在地暫停 for 循環(huán)的下一次迭代
await updateUserStatus(id);
}
console.log("--- 所有用戶更新完畢!(這次是真的) ---");
}
運(yùn)行結(jié)果:
這完全符合我們的直覺:等待上一個(gè)完成后,再開始下一個(gè)。
方案二:效率先鋒 Promise.all
+ map
(并行執(zhí)行)
在很多場(chǎng)景下,我們并不需要嚴(yán)格地按順序執(zhí)行。這些異步任務(wù)之間沒有依賴關(guān)系,完全可以并行處理以提高效率。這時(shí),map
和 Promise.all
的組合就閃亮登場(chǎng)了。
Array.prototype.map
:與 forEach
不同,map
會(huì)返回一個(gè)新數(shù)組。當(dāng)我們給它一個(gè) async
函數(shù)時(shí),它會(huì)同步地返回一個(gè)由 pending
Promise 組成的數(shù)組。Promise.all
:這個(gè)方法接收一個(gè) Promise 數(shù)組,并返回一個(gè)新的 Promise。只有當(dāng)數(shù)組中所有的 Promise 都成功完成(resolved)時(shí),這個(gè)新的 Promise 才會(huì)完成。
async function batchUpdateUsersInParallel(ids) {
console.log("--- 開始批量更新 (并行執(zhí)行) ---");
// 1. map 會(huì)立即返回一個(gè) Promise 數(shù)組
const promises = ids.map(id => updateUserStatus(id));
// 2. Promise.all 會(huì)等待所有 promises 完成
await Promise.all(promises);
console.log("--- 所有用戶更新完畢!(這次是真的,而且很快) ---");
}
運(yùn)行結(jié)果:
這種方式的總耗時(shí)約等于最慢的那個(gè)異步任務(wù)的耗時(shí),效率極高。
方案三:更靈活的 for...in
和傳統(tǒng) for
循環(huán)
for...in
(用于遍歷對(duì)象鍵)和傳統(tǒng)的 for (let i = 0; ...)
循環(huán)同樣支持 await
。它們的工作方式與 for...of
類似,都會(huì)等待 await
的 Promise 完成。
// 傳統(tǒng) for 循環(huán)
for (let i = 0; i < ids.length; i++) {
await updateUserStatus(ids[i]);
}
為了防止你和我一樣踩坑,這里有一份速記備忘錄:需要按順序執(zhí)行使用 for...of
;需要并行執(zhí)行,提高效率使用 Promise.all
+ map
,性能最佳,但要注意并發(fā)數(shù)過高可能帶來的問題;絕對(duì)不要用 forEach
,它不會(huì)等待我們的 await
,它只會(huì)無情地觸發(fā)。
閱讀原文:https://mp.weixin.qq.com/s/QUynwSg3aBjzsNo5WttXDQ
該文章在 2025/7/1 9:36:26 編輯過