整理筆記的時(shí)候我習(xí)慣把一個(gè)主題拆成獨(dú)立項(xiàng)目來(lái)歸檔。loopx 就是其中一個(gè)以“循環(huán)”為主線做技術(shù)梳理的項(xiàng)目名它既是一個(gè)學(xué)習(xí)索引也是一組工具函數(shù)集合專門用來(lái)總結(jié)循環(huán)相關(guān)的基礎(chǔ)語(yǔ)法、異步事件循環(huán)、循環(huán)依賴以及死循環(huán)排查等內(nèi)容。循環(huán)在編程里看似簡(jiǎn)單但真正放到并發(fā)場(chǎng)景、依賴管理、線上故障排查中就會(huì)發(fā)現(xiàn)“會(huì)寫 for”只是第一步理解循環(huán)背后的機(jī)制更重要。本文適合剛?cè)腴T但不想只停留在語(yǔ)法的初學(xué)者也適合需要系統(tǒng)排查循環(huán)依賴、處理事件循環(huán)阻塞問(wèn)題的后端開(kāi)發(fā)者。整篇文章會(huì)圍繞“循環(huán)”這條主線展開(kāi)從語(yǔ)法、事件循環(huán)、循環(huán)依賴到實(shí)戰(zhàn)工具函數(shù)和線上排查方法一次性把環(huán)的概念和坑點(diǎn)梳理清楚。1. 背景與核心概念1.1 為什么整理 loopx 這個(gè)循環(huán)專題日常開(kāi)發(fā)中“循環(huán)”這個(gè)詞有多種含義第一次接觸時(shí)很容易混在一起。比如我們寫for i in range(10)是循環(huán)Node.js 里的 Event Loop事件循環(huán)也是循環(huán)Spring 啟動(dòng)時(shí)出現(xiàn)的循環(huán)依賴錯(cuò)誤還是“循環(huán)”。它們的共同點(diǎn)是“形成了一個(gè)環(huán)”但解決問(wèn)題的思路完全不同。我整理 loopx 的初衷就是把這些“環(huán)”分開(kāi)寫代碼時(shí)的循環(huán)是語(yǔ)法問(wèn)題事件循環(huán)是運(yùn)行時(shí)調(diào)度問(wèn)題循環(huán)依賴是架構(gòu)設(shè)計(jì)問(wèn)題死循環(huán)是代碼質(zhì)量與運(yùn)維問(wèn)題。把它們放到一個(gè)專題里對(duì)比學(xué)習(xí)理解會(huì)更高效。否則遇到一個(gè)“循環(huán)”報(bào)錯(cuò)可能連搜索引擎都不知道該用哪個(gè)關(guān)鍵詞。因此本文不會(huì)只講一種語(yǔ)言的一種循環(huán)寫法而是把循環(huán)相關(guān)的知識(shí)點(diǎn)打通提供一個(gè)能直接套用的排查思路和工具函數(shù)集。1.2 循環(huán)技術(shù)涉及的范圍loopx 項(xiàng)目里覆蓋的內(nèi)容主要有四類分類代表問(wèn)題說(shuō)明語(yǔ)法循環(huán)for、while、迭代器、生成器解決“怎么寫循環(huán)”的問(wèn)題事件循環(huán)Node.js Event Loop、瀏覽器事件循環(huán)、asyncio解決“異步任務(wù)如何調(diào)度”的問(wèn)題循環(huán)依賴Spring Bean 循環(huán)依賴、Maven 循環(huán)依賴、數(shù)據(jù)庫(kù)外鍵循環(huán)解決“模塊互相引用”的問(wèn)題異常循環(huán)死循環(huán)、CPU 飆高、阻塞事件循環(huán)解決“循環(huán)導(dǎo)致系統(tǒng)不可用”的問(wèn)題從這張表可以看到loopx 不是某個(gè)熱門開(kāi)源框架而是一套圍繞循環(huán)場(chǎng)景整理的技術(shù)地圖。后續(xù)章節(jié)會(huì)按這個(gè)地圖展開(kāi)最終還會(huì)給出一個(gè)可直接復(fù)用的 Python 工具函數(shù)模塊方便日常開(kāi)發(fā)中直接使用。1.3 本文適合讀者與學(xué)習(xí)目標(biāo)如果你滿足以下任一種情況本文會(huì)比較適合你剛學(xué)習(xí)編程想系統(tǒng)理解 for、while、迭代器、生成器的區(qū)別和使用場(chǎng)景。用 Node.js、Python 做過(guò)異步開(kāi)發(fā)但沒(méi)想清楚事件循環(huán)和異步回調(diào)的關(guān)系。在 Spring 或 Maven 項(xiàng)目里遇到循環(huán)依賴報(bào)錯(cuò)希望了解成因與解決方案。遇到線上 CPU 飆高、程序卡死的問(wèn)題需要掌握死循環(huán)排查流程。需要在項(xiàng)目中做批量任務(wù)、重試機(jī)制、分塊處理想借鑒一組成熟的循環(huán)工具函數(shù)。讀完后你會(huì)得到三類收獲循環(huán)語(yǔ)法的多語(yǔ)言對(duì)比、循環(huán)依賴的解決方案、一組可復(fù)制到項(xiàng)目里的工具函數(shù)和排查清單。2. 環(huán)境準(zhǔn)備與實(shí)驗(yàn)約定2.1 運(yùn)行環(huán)境本文示例以常見(jiàn)開(kāi)發(fā)環(huán)境為例具體版本需要根據(jù)你的項(xiàng)目實(shí)際情況調(diào)整。操作系統(tǒng)Windows 10/11、macOS、Linux 均可本文示例不依賴特定系統(tǒng)命令。Python建議 3.8 及以上版本用于運(yùn)行 loopx 工具函數(shù)示例。Node.js建議 16 及以上版本用于演示事件循環(huán)。Java建議 8 及以上版本用于理解 Spring 循環(huán)依賴示例。IDE推薦 VS Code 或 PyCharm隨手測(cè)試 Python 代碼比較方便。如果你本機(jī)版本較低例如 Python 3.6部分類型注解可能不兼容稍微修改即可運(yùn)行不影響整體思路。2.2 代碼示例的結(jié)構(gòu)為了讓示例有真實(shí)感本文會(huì)按以下目錄結(jié)構(gòu)組織代碼loopx/ ├── loopx.py # 循環(huán)工具函數(shù)集合 ├── test_loopx.py # 簡(jiǎn)單測(cè)試腳本 ├── event_loop_demo.js # Node.js 事件循環(huán)示例 └── README.md # 說(shuō)明文檔可選代碼示例會(huì)盡量保持獨(dú)立可運(yùn)行。涉及第三方庫(kù)時(shí)會(huì)在對(duì)應(yīng)位置說(shuō)明安裝命令沒(méi)有依賴的示例則直接使用標(biāo)準(zhǔn)庫(kù)完成。你不需要一開(kāi)始就搭建完整工程可以先新建一個(gè)loopx.py文件邊看邊把函數(shù)復(fù)制進(jìn)去測(cè)試。3. 常用編程語(yǔ)言中的循環(huán)語(yǔ)法拆解循環(huán)是編程語(yǔ)言里最基礎(chǔ)也最容易寫出“反直覺(jué)代碼”的部分。下面分別看 Python、Java、JavaScript 三種語(yǔ)言的常見(jiàn)寫法重點(diǎn)不是羅列語(yǔ)法而是對(duì)比它們的邊界條件。3.1 Python 循環(huán)遍歷風(fēng)格與生成器Python 中最常用的是for...in循環(huán)。它與 C 語(yǔ)言的 for 不太一樣本質(zhì)是“迭代器遍歷”。可以直接遍歷列表、元組、字典、集合、字符串等可迭代對(duì)象。# 遍歷列表 names [Alice, Bob, Charlie] for name in names: print(name) # 遍歷字典 user {name: Tom, age: 18} for key, value in user.items(): print(key, value) # 使用 range 生成數(shù)字序列 for i in range(1, 5): print(i)這里需要注意range的行為range(1, 5)會(huì)輸出 1 到 4不包含 5。如果寫成range(5)輸出 0 到 4。新手經(jīng)常在邊界這里踩坑比如想輸出 1 到 100寫成了range(1, 100)漏掉了 100。Python 還有一個(gè)特性是for...else。當(dāng)循環(huán)正常結(jié)束沒(méi)有被 break 中斷時(shí)else塊會(huì)執(zhí)行。很多教程會(huì)忽略它但它非常適合用來(lái)做“查找失敗后的兜底處理”。target 8 numbers [1, 3, 5, 7, 9] for n in numbers: if n target: print(找到了, n) break else: print(沒(méi)有找到, target)此外Python 的列表推導(dǎo)式在簡(jiǎn)單循環(huán)場(chǎng)景下比 for 更簡(jiǎn)潔squares [x * x for x in range(10)] print(squares)這里等價(jià)于squares [] for x in range(10): squares.append(x * x)生成器是循環(huán)場(chǎng)景中另一個(gè)重要概念。把列表推導(dǎo)式的方括號(hào)改成圓括號(hào)就變成了生成器表達(dá)式它可以避免一次性創(chuàng)建大量數(shù)據(jù)在內(nèi)存里gen (x * x for x in range(1000000)) print(sum(gen))這個(gè)例子中如果使用列表推導(dǎo)式會(huì)一次性生成百萬(wàn)個(gè)元素而生成器是邊遍歷邊計(jì)算內(nèi)存占用低很多。實(shí)際處理大文件、大日志、接口分頁(yè)數(shù)據(jù)時(shí)生成器幾乎是最優(yōu)選擇。3.2 Java 循環(huán)for、for-each 與 StreamJava 中傳統(tǒng) for 循環(huán)仍然很常用尤其是需要下標(biāo)訪問(wèn)的場(chǎng)景。經(jīng)典寫法如下int[] nums {1, 2, 3, 4, 5}; for (int i 0; i nums.length; i) { System.out.println(nums[i]); }增強(qiáng) for 循環(huán)for-each適合只遍歷不改結(jié)構(gòu)的情況ListString names Arrays.asList(Alice, Bob); for (String name : names) { System.out.println(name); }需要注意的是for-each 遍歷時(shí)不能直接調(diào)用list.remove()否則會(huì)拋出ConcurrentModificationException。如果需要在遍歷過(guò)程中刪除元素應(yīng)使用迭代器ListString list new ArrayList(Arrays.asList(A, B, C)); IteratorString it list.iterator(); while (it.hasNext()) { String item it.next(); if (B.equals(item)) { it.remove(); } }Java 8 之后的 Stream 也提供了類似循環(huán)的能力適合過(guò)濾、轉(zhuǎn)換、聚合邏輯ListInteger numbers Arrays.asList(1, 2, 3, 4, 5); ListInteger evens numbers.stream() .filter(n - n % 2 0) .collect(Collectors.toList()); System.out.println(evens);這里 filter 替代了 for if 的寫法代碼更聲明式。但要注意Stream 不是所有循環(huán)場(chǎng)景的替代品比如狀態(tài)化循環(huán)、需要下標(biāo)或者需要提前中斷的復(fù)雜邏輯傳統(tǒng) for 更合適。3.3 JavaScript 循環(huán)for...of、forEach 與退出機(jī)制JavaScript 中有多種遍歷方式最容易混淆的是forEach與for...of。const arr [10, 20, 30]; // for...of for (const item of arr) { if (item 20) { break; } console.log(item); } // forEach arr.forEach((item) { console.log(item); });關(guān)鍵區(qū)別是for...of可以使用break、continue、return控制流程而forEach不能直接 break只能通過(guò)拋出異?；蛱崆?return 跳過(guò)本次回調(diào)。換句話說(shuō)如果需要中斷遍歷用for...of或傳統(tǒng) for。JavaScript 中遍歷對(duì)象的屬性可以用for...in但它會(huì)包含原型鏈上的可枚舉屬性一般建議配合Object.prototype.hasOwnProperty判斷。否則容易遍歷出非自身屬性引發(fā)意外結(jié)果。const obj { name: loopx, type: note }; for (const key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { console.log(key, obj[key]); } }日常遍歷數(shù)組推薦for...of需要 key-value 時(shí)用Object.entries()const obj { name: loopx, type: note }; for (const [key, value] of Object.entries(obj)) { console.log(key, value); }掌握語(yǔ)法只是第一步。下面進(jìn)入事件循環(huán)部分看看異步場(chǎng)景里“循環(huán)”是如何運(yùn)轉(zhuǎn)的。4. 事件循環(huán)異步編程的底層機(jī)制4.1 為什么需要事件循環(huán)如果你只寫同步代碼事件循環(huán)對(duì)你來(lái)說(shuō)可能沒(méi)什么存在感。但一旦涉及網(wǎng)絡(luò)請(qǐng)求、文件讀寫、定時(shí)器、數(shù)據(jù)庫(kù)操作異步機(jī)制就不可回避。以 Node.js 為例JavaScript 是單線程的不可能同時(shí)執(zhí)行兩段代碼。為了實(shí)現(xiàn)高并發(fā)的 I/O 處理Node.js 引入了事件循環(huán)機(jī)制主線程先把耗時(shí)的 I/O 操作交給底層線程池或系統(tǒng)內(nèi)核處理自己繼續(xù)執(zhí)行后面的任務(wù)當(dāng) I/O 完成后系統(tǒng)通知 Node.js 把對(duì)應(yīng)的回調(diào)放入隊(duì)列在合適的時(shí)機(jī)取出來(lái)執(zhí)行。這個(gè)“取出來(lái)執(zhí)行”的時(shí)機(jī)就是事件循環(huán)調(diào)度的過(guò)程。如果理解不到位經(jīng)常會(huì)寫出“明明先寫了setTimeout卻是最后執(zhí)行的”的疑惑代碼。4.2 Node.js 事件循環(huán)與微任務(wù)Node.js 的事件循環(huán)分為多個(gè)階段主要包括timers執(zhí)行setTimeout、setInterval的回調(diào)。pending callbacks執(zhí)行上一輪延遲到現(xiàn)在的 I/O 回調(diào)。idle/prepare內(nèi)部使用階段。poll獲取新的 I/O 事件執(zhí)行與 I/O 相關(guān)的回調(diào)。check執(zhí)行setImmediate回調(diào)。close callbacks執(zhí)行 socket 或 handle 的 close 事件回調(diào)。每個(gè)階段結(jié)束后會(huì)先執(zhí)行微任務(wù)隊(duì)列。所謂微任務(wù)指的是Promise.then、process.nextTick、queueMicrotask等回調(diào)。微任務(wù)會(huì)在當(dāng)前階段結(jié)束、進(jìn)入下一階段之前把隊(duì)列清空。看一個(gè)示例console.log(1); setTimeout(() { console.log(2); }, 0); Promise.resolve().then(() { console.log(3); }); console.log(4);輸出順序是1 4 3 2原因是同步代碼先執(zhí)行輸出 1、4Promise 的回調(diào)屬于微任務(wù)在同步代碼結(jié)束后、setTimeout 定時(shí)器回調(diào)之前執(zhí)行所以輸出 3 排在前面最后才輪到 0 毫秒定時(shí)器回調(diào)輸出 2。這個(gè)現(xiàn)象在面試和日常開(kāi)發(fā)中都很常見(jiàn)。如果你在使用定時(shí)器卻發(fā)現(xiàn)回調(diào)遲遲不執(zhí)行先想想事件循環(huán)階段與微任務(wù)的執(zhí)行順序是不是有長(zhǎng)任務(wù)阻塞了循環(huán)。4.3 Python asyncio 事件循環(huán)Python 3.4 引入 asyncio用于編寫異步 I/O 代碼。asyncio 的核心也是一個(gè)事件循環(huán)它不斷檢查任務(wù)隊(duì)列找到可以執(zhí)行的任務(wù)并調(diào)度。import asyncio async def say_hello(): print(hello) await asyncio.sleep(1) print(world) async def main(): await asyncio.gather( say_hello(), say_hello(), ) asyncio.run(main())上面代碼中兩個(gè)say_hello()協(xié)程并發(fā)執(zhí)行總耗時(shí)約 1 秒而不是 2 秒。原因是遇到await asyncio.sleep(1)時(shí)協(xié)程讓出控制權(quán)事件循環(huán)會(huì)調(diào)度另一個(gè)協(xié)程繼續(xù)執(zhí)行。使用 asyncio 最常見(jiàn)的誤區(qū)是在協(xié)程中寫了time.sleep()而不是await asyncio.sleep()導(dǎo)致事件循環(huán)被阻塞其他協(xié)程全部卡住。原因在于time.sleep()是同步阻塞調(diào)用會(huì)讓頂層循環(huán)停住。import asyncio import time async def bad_func(): time.sleep(1) # 錯(cuò)誤示范阻塞事件循環(huán) async def good_func(): await asyncio.sleep(1) # 正確讓出控制權(quán)所以在 asyncio 代碼中凡是可能阻塞的操作盡量換成對(duì)應(yīng)的異步版本。如果確有必要調(diào)用同步阻塞的第三方庫(kù)通常需要把它放到線程池中執(zhí)行避免拖死整個(gè)事件循環(huán)。5. 循環(huán)依賴工程中的“環(huán)”問(wèn)題5.1 Spring Bean 循環(huán)依賴Spring 項(xiàng)目中當(dāng) Bean A 依賴 Bean B而 Bean B 又依賴 Bean A 時(shí)就會(huì)形成循環(huán)依賴。Spring 默認(rèn)對(duì)單例 Bean 的 Setter 注入循環(huán)依賴是支持的但構(gòu)造器注入的循環(huán)依賴默認(rèn)無(wú)法解決啟動(dòng)時(shí)會(huì)出現(xiàn)類似下面的報(bào)錯(cuò)Requested bean is currently in creation: Is there an unresolvable circular reference?解決思路一般有三種構(gòu)造器注入改為 Setter 注入或字段注入利用三級(jí)緩存提前暴露對(duì)象。使用Lazy注解在注入處生成一個(gè)代理對(duì)象延遲真正依賴的解析。重新梳理對(duì)象職責(zé)把互相依賴的代碼做拆分這是根本解法。Service public class AService { private final BService bService; public AService(Lazy BService bService) { this.bService bService; } }實(shí)際項(xiàng)目中不建議為了繞過(guò)循環(huán)依賴盲目使用Lazy。循環(huán)依賴往往是設(shè)計(jì)問(wèn)題的信號(hào)優(yōu)先調(diào)整分層讓依賴方向變得清晰。5.2 Maven 循環(huán)依賴Maven 多模塊項(xiàng)目里如果 module-a 依賴 module-b而 module-b 又依賴 module-a構(gòu)建時(shí)會(huì)報(bào)Dependency cycle錯(cuò)誤。Maven 不允許模塊之間存在循環(huán)依賴因?yàn)檫@會(huì)破壞構(gòu)建順序的確定性。排查方法是用依賴分析插件mvn dependency:tree然后觀察模塊之間的依賴方向。解決思路通常是抽取公共模塊把 A 和 B 都依賴的公共類放到 module-common讓 A 和 B 都指向它。依賴方向變成“樹狀”而不是“環(huán)狀”。5.3 數(shù)據(jù)庫(kù)外鍵循環(huán)引用數(shù)據(jù)庫(kù)表設(shè)計(jì)同樣存在循環(huán)引用。例如用戶表 user、訂單表 orderuser 有默認(rèn)收貨地址字段指向 order 表order 又有 user_id 外鍵指向 user 表兩個(gè)表互相外鍵引用。這種設(shè)計(jì)在插入數(shù)據(jù)時(shí)很容易因?yàn)榧s束校驗(yàn)導(dǎo)致失敗。實(shí)踐建議是能不使用物理外鍵就不要使用用應(yīng)用層邏輯維護(hù)關(guān)聯(lián)關(guān)系。如果必須保留外鍵刪除數(shù)據(jù)時(shí)要先刪除子表記錄再刪除父表記錄。需要修改時(shí)先禁用或延遲約束檢查再執(zhí)行 DML執(zhí)行完恢復(fù)。這種“循環(huán)引用”帶來(lái)的問(wèn)題不是語(yǔ)法層面的而是架構(gòu)和數(shù)據(jù)字典層面的。提前評(píng)估表關(guān)系能省下很多運(yùn)維成本。6. 完整實(shí)戰(zhàn)案例loopx 循環(huán)工具函數(shù)集6.1 需求與函數(shù)設(shè)計(jì)了解了循環(huán)相關(guān)概念后下面實(shí)現(xiàn)一個(gè)輕量工具模塊 loopx.py。這個(gè)模塊不是重復(fù)造輪子而是把循環(huán)場(chǎng)景里常用的能力集中起來(lái)方便以后復(fù)制到項(xiàng)目中使用。我設(shè)計(jì)了四個(gè)核心函數(shù)safe_range帶邊界保護(hù)的數(shù)字序列生成函數(shù)避免不小心產(chǎn)生無(wú)限循環(huán)。retry帶重試次數(shù)的循環(huán)執(zhí)行函數(shù)適合處理網(wǎng)絡(luò)抖動(dòng)等臨時(shí)錯(cuò)誤。chunked把大列表分成小批次適合分批寫庫(kù)或分批請(qǐng)求接口。run_with_deadline帶超時(shí)控制的循環(huán)執(zhí)行函數(shù)避免任務(wù)卡死。整體的設(shè)計(jì)思路是循環(huán)不要裸寫要加限制、加超時(shí)、加批次這些是工程化使用循環(huán)的基本要求。6.2 完整代碼新建loopx.py內(nèi)容如下# 文件路徑loopx/loopx.py loopx循環(huán)場(chǎng)景工具函數(shù)集合。 import time from typing import Any, Callable, Iterable, List, Optional def safe_range(start: int, end: Optional[int] None, step: int 1) - Iterable[int]: 安全地生成數(shù)字序列。 如果只傳一個(gè)參數(shù)則按 range(end) 處理如果 end 為 None則返回空迭代器。 主要作用是避免因參數(shù)錯(cuò)誤導(dǎo)致無(wú)限循環(huán)。 if end is None: end start start 0 if step 0: raise ValueError(step 不能為 0) return range(start, end, step) def retry( func: Callable[[], Any], max_retries: int 3, delay: float 0.5, exceptions: tuple (Exception,), ) - Any: 循環(huán)執(zhí)行 func并支持失敗重試。 :param func: 需要執(zhí)行的函數(shù) :param max_retries: 最多重試次數(shù) :param delay: 每次重試之間等待的秒數(shù) :param exceptions: 需要捕獲的異常類型 :return: func 的返回值 attempt 0 while attempt max_retries: try: return func() except exceptions as e: attempt 1 if attempt max_retries: raise print(f第 {attempt} 次執(zhí)行失敗{e}{delay} 秒后重試...) time.sleep(delay) return None def chunked(data: List[Any], size: int) - Iterable[List[Any]]: 將列表按指定大小分塊。 :param data: 輸入列表 :param size: 每個(gè)分塊的最大元素?cái)?shù)量 if size 0: raise ValueError(size 必須大于 0) for i in range(0, len(data), size): yield data[i:i size] def run_with_deadline( func: Callable[[], Any], timeout: float 5.0, poll_interval: float 0.1, ) - Any: 在指定時(shí)間內(nèi)循環(huán)執(zhí)行 func直到成功或超時(shí)。 適用于等待某個(gè)條件成立的場(chǎng)景。 :param func: 返回 True 表示成功False 表示繼續(xù)循環(huán) :param timeout: 最長(zhǎng)等待時(shí)間秒 :param poll_interval: 狀態(tài)檢查間隔秒 start_time time.time() while True: result func() if result: return result if time.time() - start_time timeout: raise TimeoutError(f等待超時(shí)超過(guò) {timeout} 秒) time.sleep(poll_interval)為了讓模塊更完善再補(bǔ)充一個(gè)讀取大量日志并按批次統(tǒng)計(jì)需求的小函數(shù)def count_in_chunks(file_path: str, keyword: str, chunk_size: int 10000): 分塊讀取文件統(tǒng)計(jì)包含指定關(guān)鍵字的行數(shù)。 避免一次性把大文件全部讀入內(nèi)存。 count 0 buffer [] with open(file_path, r, encodingutf-8) as f: for line in f: buffer.append(line) if len(buffer) chunk_size: count sum(1 for item in buffer if keyword in item) buffer.clear() if buffer: count sum(1 for item in buffer if keyword in item) return count6.3 測(cè)試與輸出新建test_loopx.py驗(yàn)證函數(shù)是否能按預(yù)期工作# 文件路徑loopx/test_loopx.py from loopx import chunked, retry, run_with_deadline, safe_range def test_safe_range(): assert list(safe_range(5)) [0, 1, 2, 3, 4] assert list(safe_range(1, 5)) [1, 2, 3, 4] print(safe_range 測(cè)試通過(guò)) def test_chunked(): assert list(chunked([1, 2, 3, 4, 5], 2)) [[1, 2], [3, 4], [5]] print(chunked 測(cè)試通過(guò)) def test_retry(): call_count 0 def flaky_func(): nonlocal call_count call_count 1 if call_count 3: raise RuntimeError(臨時(shí)錯(cuò)誤) return ok result retry(flaky_func, max_retries3, delay0.1) assert result ok print(retry 測(cè)試通過(guò)) def test_run_with_deadline(): state {count: 0} def wait_func(): state[count] 1 return state[count] 3 result run_with_deadline(wait_func, timeout2, poll_interval0.05) assert result is True print(run_with_deadline 測(cè)試通過(guò)) if __name__ __main__: test_safe_range() test_chunked() test_retry() test_run_with_deadline() print(全部測(cè)試通過(guò))運(yùn)行測(cè)試python test_loopx.py預(yù)期輸出safe_range 測(cè)試通過(guò) chunked 測(cè)試通過(guò) retry 測(cè)試通過(guò) run_with_deadline 測(cè)試通過(guò) 全部測(cè)試通過(guò)6.4 運(yùn)行思路與實(shí)際使用建議為什么把 retry 函數(shù)單獨(dú)抽出來(lái)因?yàn)樵趯?shí)際項(xiàng)目中網(wǎng)絡(luò)請(qǐng)求、數(shù)據(jù)庫(kù)連接、下游 RPC 都可能臨時(shí)失敗直接在業(yè)務(wù)代碼里寫多層 while try 既不美觀也無(wú)法統(tǒng)一控制重試次數(shù)和等待時(shí)間。抽成工具函數(shù)后調(diào)用方只需要寫一行data retry(lambda: call_remote_api(), max_retries5, delay1.0)chunked 函數(shù)則非常適合批量寫入場(chǎng)景。例如一次需要處理 10 萬(wàn)條數(shù)據(jù)直接循環(huán)容易造成內(nèi)存壓力分批處理更平穩(wěn)for batch in chunked(all_ids, size500): batch_update_status(batch)run_with_deadline 適合輪詢等待某個(gè)資源就緒的場(chǎng)景比如等待接口返回狀態(tài)、等待文件生成完成。結(jié)合超時(shí)時(shí)間可以避免因?yàn)橐蕾嚨姆?wù)沒(méi)響應(yīng)而讓進(jìn)程掛死。7. 死循環(huán)與高 CPU 問(wèn)題的排查思路7.1 常見(jiàn)死循環(huán)類型死循環(huán)是循環(huán)場(chǎng)景中最容易引發(fā)線上事故的問(wèn)題典型類型包括忘記更新循環(huán)變量或循環(huán)條件永遠(yuǎn)為真。在遞歸函數(shù)中缺少終止條件。for 循環(huán)遍歷集合時(shí)不斷往集合里追加元素導(dǎo)致永不結(jié)束。循環(huán)內(nèi) catch 住了所有異常并不斷重試沒(méi)有退出條件。多線程場(chǎng)景中因?yàn)殒i等待造成邏輯死鎖雖然不是嚴(yán)格意義上的死循環(huán)但表現(xiàn)同樣是“卡死”。我先看一個(gè)最典型的 Python 死循環(huán)i 0 while i 10: print(i) # 忘記寫 i 1導(dǎo)致 i 永遠(yuǎn)為 0這段代碼會(huì)無(wú)限打印 0。解決方式是確保每次循環(huán)都改變循環(huán)變量的值或者在循環(huán)內(nèi)設(shè)置明確的退出路徑i 0 while i 10: print(i) i 1還有一類隱藏坑遍歷列表時(shí)修改列表。nums [1, 2, 3, 4, 5] for n in nums: if n % 2 0: nums.remove(n)這種代碼在 Python 中雖然不會(huì)拋錯(cuò)但結(jié)果不符合預(yù)期因?yàn)楸闅v時(shí)列表長(zhǎng)度在變化。更安全的方式是創(chuàng)建副本后再遍歷nums [1, 2, 3, 4, 5] for n in nums[:]: if n % 2 0: nums.remove(n)7.2 線上定位流程如果線上應(yīng)用 CPU 飆高懷疑死循環(huán)導(dǎo)致可以按以下流程排查使用top命令查看 CPU 占用最高的進(jìn)程 PID。使用top -Hp PID查看進(jìn)程內(nèi)線程的 CPU 占用。如果是 Java 應(yīng)用使用jstack PID導(dǎo)出線程快照搜索RUNNABLE狀態(tài)的線程查看它的調(diào)用棧找到卡住的業(yè)務(wù)循環(huán)。如果是 Python 應(yīng)用可以使用py-spy dump --pid PID查看當(dāng)前執(zhí)行棧。如果是 Node.js 應(yīng)用可以在啟動(dòng)時(shí)加--inspect用 Chrome DevTools 的 Profiler 抓取 CPU Profile定位熱點(diǎn)函數(shù)。定位到具體代碼后重點(diǎn)關(guān)注循環(huán)條件和退出條件尤其是while True、for內(nèi)部有無(wú) break、continue 是否誤用了標(biāo)簽等。7.3 常見(jiàn)問(wèn)題排查表問(wèn)題現(xiàn)象常見(jiàn)原因解決思路CPU 100%進(jìn)程卡住循環(huán)條件永遠(yuǎn)為真檢查循環(huán)變量和條件增加退出日志Java 啟動(dòng)時(shí)報(bào) Circular referenceSpring 構(gòu)造器注入循環(huán)依賴改用 Setter 注入、Lazy 或拆分模塊Node.js 定時(shí)器回調(diào)延遲嚴(yán)重主線程被同步循環(huán)阻塞優(yōu)化同步邏輯或拆分成異步批次Python asyncio 協(xié)程不執(zhí)行協(xié)程中調(diào)用了 time.sleep改用 await asyncio.sleep遍歷集合時(shí)異常循環(huán)中修改集合結(jié)構(gòu)使用副本遍歷或迭代器 remove下游接口偶發(fā)超時(shí)沒(méi)有重試機(jī)制引入帶超時(shí)的 retry 工具函數(shù)大數(shù)據(jù)量批量處理內(nèi)存溢出一次性加載全部數(shù)據(jù)使用 chunked 分批處理8. 最佳實(shí)踐與工程建議8.1 循環(huán)書寫的通用規(guī)范先總結(jié)幾條所有語(yǔ)言通用規(guī)范循環(huán)前先確認(rèn)邊界條件尤其是start、end、step的值是否會(huì)無(wú)限循環(huán)。循環(huán)體盡量短小。如果循環(huán)體超過(guò) 20 行先考慮抽函數(shù)。不要裸用while True除非你在循環(huán)體內(nèi)有明確的 break 條件。在循環(huán)開(kāi)頭或結(jié)尾增加必要日志但避免在高頻循環(huán)里每次都打日志。優(yōu)先使用語(yǔ)言提供的推導(dǎo)式、迭代器、Stream 等高級(jí)能力但不要過(guò)度封裝導(dǎo)致可讀性下降。遍歷集合時(shí)不要修改集合的長(zhǎng)度和結(jié)構(gòu)。一個(gè)比較推薦的模式是“循環(huán) 狀態(tài) 超時(shí)”deadline time.time() 30 while time.time() deadline: result try_do_something() if result.is_success(): break time.sleep(0.5)這樣能夠確保代碼不會(huì)因?yàn)楫惓Ｇ闆r無(wú)限等待。8.2 異步循環(huán)注意事項(xiàng)在異步環(huán)境寫循環(huán)時(shí)有幾個(gè)額外注意點(diǎn)不要在協(xié)程中使用同步阻塞調(diào)用否則會(huì)阻塞整個(gè)事件循環(huán)。異步循環(huán)中創(chuàng)建大量任務(wù)時(shí)要控制并發(fā)度不要一次性create_task幾千個(gè)。重試循環(huán)必須設(shè)置最大次數(shù)和超時(shí)時(shí)間避免異常導(dǎo)致無(wú)限重試打爆下游服務(wù)。定時(shí)器循環(huán)任務(wù)要考慮上一次執(zhí)行是否完成。如果上一次沒(méi)執(zhí)行完下一次又開(kāi)始執(zhí)行會(huì)造成任務(wù)堆積。在 Node.js 中如果要做定時(shí)批量任務(wù)可以用setInterval但要防止重入let running false; setInterval(async () { if (running) { console.log(上一次任務(wù)尚未完成跳過(guò)本次執(zhí)行); return; } running true; try { await doBatch(); } finally { running false; } }, 1000);在 Python asyncio 中也有類似問(wèn)題通常使用asyncio.Lock或一個(gè)簡(jiǎn)單的布爾標(biāo)志位。8.3 循環(huán)依賴規(guī)避策略循環(huán)依賴是架構(gòu)層面最容易忽略的問(wèn)題。建議從以下角度規(guī)避依賴方向保持單向。上層模塊可以依賴下層模塊下層模塊不要反向依賴上層。遇到 Spring 循環(huán)依賴優(yōu)先考慮拆分 Service而不是直接加Lazy。Maven 多模塊項(xiàng)目遵循“common 模塊只被依賴不依賴業(yè)務(wù)模塊”原則。數(shù)據(jù)庫(kù)表之間的外鍵不要設(shè)計(jì)成雙向約束使用應(yīng)用層事務(wù)保證數(shù)據(jù)一致性。代碼評(píng)審時(shí)把“新增依賴是否形成循環(huán)”作為必查項(xiàng)。使用jdeps或 Maven 依賴插件定期檢查模塊依賴關(guān)系也能幫助早期發(fā)現(xiàn)問(wèn)題。8.4 可觀測(cè)性與監(jiān)控涉及循環(huán)的應(yīng)用最好增加可觀測(cè)性循環(huán)任務(wù)開(kāi)始和結(jié)束時(shí)記錄任務(wù)名稱、耗時(shí)、成功狀態(tài)。重試次數(shù)、失敗原因要記錄到結(jié)構(gòu)化日志或監(jiān)控指標(biāo)中。給死循環(huán)場(chǎng)景設(shè)計(jì)告警CPU 使用率超過(guò)閾值、任務(wù)執(zhí)行時(shí)間超過(guò)預(yù)期、重試次數(shù)過(guò)多都要觸發(fā)告警。進(jìn)程啟動(dòng)時(shí)可以做一次自檢比如檢查配置文件里的循環(huán)次數(shù)是否在合理范圍。監(jiān)控不是代碼寫完后的額外工作而應(yīng)該從一開(kāi)始就納入設(shè)計(jì)。尤其是定時(shí)任務(wù)、消息消費(fèi)、批量處理這類循環(huán)密集型任務(wù)沒(méi)有監(jiān)控意味著故障發(fā)生時(shí)很難快速定位。9. 后續(xù)學(xué)習(xí)路線與項(xiàng)目實(shí)踐建議從 loopx 這個(gè)專題延伸出去你可以繼續(xù)研究以下方向深入學(xué)習(xí)生成器和迭代器協(xié)議理解 Python 循環(huán)背后的迭代機(jī)制。閱讀 Node.js 事件循環(huán)官方文檔結(jié)合process.nextTick、setImmediate、Promise、queueMicrotask徹底搞懂執(zhí)行順序。在 Spring 項(xiàng)目中嘗試用DependsOn、Lazy等注解解決不同的依賴順序問(wèn)題。自己實(shí)現(xiàn)一個(gè)簡(jiǎn)化的事件循環(huán)加深對(duì)異步調(diào)度的理解。把文中的 loopx.py 擴(kuò)展成包含滑動(dòng)窗口、令牌桶限流、異步重試等更多能力的工具包。實(shí)際項(xiàng)目中優(yōu)先關(guān)注三類風(fēng)險(xiǎn)線上死循環(huán)導(dǎo)致的高 CPU、異步事件循環(huán)被阻塞導(dǎo)致的延遲升高、模塊循環(huán)依賴導(dǎo)致的構(gòu)建與啟動(dòng)失敗。每類風(fēng)險(xiǎn)都建議在測(cè)試環(huán)境通過(guò)混沌實(shí)驗(yàn)和壓力測(cè)試提前發(fā)現(xiàn)。如果本文對(duì)你有幫助可以收藏備用。也建議你把 loopx.py 直接放進(jìn)自己的工具庫(kù)遇到類似場(chǎng)景時(shí)改一改就能用。動(dòng)手跑一遍示例比只看一遍收獲大得多。