多路復(fù)用通道
本文介紹了一個多路復(fù)用器函數(shù)，旨在將通道數(shù)組的輸出合併到單一通道中。然而，所提供的實作存在一些阻礙其功能的問題。
原始程式碼：
func Mux(channels []chan big.Int) chan big.Int {
// Count down as each channel closes. When hits zero - close ch.
n := len(channels)
// The channel to output to.
ch := make(chan big.Int, n)
// Make one go per channel.
for _, c := range channels {
go func() {
// Pump it.
for x := range c {
ch <- x
}
// It closed.
n -= 1
// Close output if all closed now.
if n == 0 {
close(ch)
}
}()
}
return ch
}
實作中的錯誤：
從多個Goroutine 關(guān)閉： n 變數(shù)在多個Goroutine 之間共享，並由每個Goroutine 更新當(dāng)goroutine 偵測到通道關(guān)閉時。當(dāng)多個 goroutine 嘗試同時存取和更新 n 時，這可能會導(dǎo)致競爭條件和意外行為。
不正確的通道捕獲：循環(huán)中創(chuàng)建的goroutine 每個捕獲相同的通道（最後一個）通道的元素），因為每次迭代時都會為c 分配通道的值，而不是傳給goroutine
已解決的問題：
為了解決這些問題，修改後的程式碼採用了更安全的技術(shù)：
使用WaitGroup ：sync.WaitGroup 用於追蹤goroutine 的完成情況。每個 Goroutine 在完成泵送資料後都會向 WaitGroup 發(fā)出訊號，主 Goroutine 會等待所有 Goroutine 完成後再關(guān)閉輸出通道。
正確的通道捕獲：每個 Goroutine 都會透過通道它應(yīng)該在 lambda 函數(shù)中監(jiān)聽，確保每個 goroutine 正確監(jiān)控其分配的通道。
改進的輸出： 修改後的程式碼產(chǎn)生預(yù)期的輸出，其中所有通道以均勻分佈的方式貢獻於輸出通道。原始輸出中觀察到的順序饋送被消除。
其他注意事項：
- 在沒有並發(fā)控制機制的情況下，使用GOMAXPROCS != 1 可以加劇共享變數(shù)存取的問題，導(dǎo)致意外結(jié)果。
- WaitGroup 方法可確保僅當(dāng)所有通道的所有資料都已處理完畢時，輸出通道才會關(guān)閉。如果沒有 WaitGroup，主 Goroutine 可能會過早關(guān)閉輸出通道，導(dǎo)致資料遺失。
以上是我們?nèi)绾握_地重複使用多個 Go 通道以避免競爭條件和資料遺失？的詳細內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！
熱AI工具
Undress AI Tool
免費脫衣圖片
Undresser.AI Undress
人工智慧驅(qū)動的應(yīng)用程序，用於創(chuàng)建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發(fā)環(huán)境
Dreamweaver CS6
視覺化網(wǎng)頁開發(fā)工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
熱門話題
如何在GO中的結(jié)構(gòu)實例上調(diào)用方法？
Jun 24, 2025 pm 03:17 PM
在Go語言中，調(diào)用結(jié)構(gòu)體方法需先定義結(jié)構(gòu)體和綁定接收者的方法，使用點號訪問。定義結(jié)構(gòu)體Rectangle後，可通過值接收者或指針接收者聲明方法；1.使用值接收者如func(rRectangle)Area()int，通過rect.Area()直接調(diào)用；2.若需修改結(jié)構(gòu)體，應(yīng)使用指針接收者如func(r*Rectangle)SetWidth(...)，Go會自動處理指針與值的轉(zhuǎn)換；3.嵌入結(jié)構(gòu)體時，內(nèi)嵌結(jié)構(gòu)體的方法會被提升，可直接通過外層結(jié)構(gòu)體調(diào)用；4.Go無需強制使用getter/setter，字
GO中的接口是什麼？如何定義它們？
Jun 22, 2025 pm 03:41 PM
在Go語言中，接口是一種定義行為而不指定實現(xiàn)方式的類型。接口由方法簽名組成，任何實現(xiàn)這些方法的類型都自動滿足該接口。例如，定義一個Speaker接口包含Speak()方法，則所有實現(xiàn)該方法的類型均可視為Speaker。接口適用於編寫通用函數(shù)、抽象實現(xiàn)細節(jié)和測試中使用mock對象。定義接口使用interface關(guān)鍵字並列出方法簽名，無需顯式聲明類型實現(xiàn)了接口。常見用例包括日誌、格式化、不同數(shù)據(jù)庫或服務(wù)的抽象，以及通知系統(tǒng)等。例如，Dog和Robot類型均可實現(xiàn)Speak方法，並傳遞給同一個Anno
將Golang服務(wù)與現(xiàn)有Python基礎(chǔ)架構(gòu)集成的策略
Jul 02, 2025 pm 04:39 PM
TOIntegrategolangServicesWithExistingPypythoninFrasture，userestapisorgrpcForinter-serviceCommunication，允許GoandGoandPyThonAppStoStoInteractSeamlessSeamLlyThroughlyThroughStandArdArdAdrotized Protoccols.1.usererestapis（ViaFrameWorkslikeSlikeSlikeGiningOandFlaskInpyThon）Orgrococo（wirs Propococo）
我如何使用時間軟件包來處理GO的時間和持續(xù)時間？
Jun 23, 2025 pm 11:21 PM
Go的time包提供了處理時間和持續(xù)時間的功能，包括獲取當(dāng)前時間、格式化日期、計算時間差、處理時區(qū)、調(diào)度和休眠等操作。要獲取當(dāng)前時間，使用time.Now()獲取Time結(jié)構(gòu)體，並可通過Year()、Month()、Day()等方法提取具體時間信息；通過Format("2006-01-0215:04:05")可將時間格式化為字符串；計算時間差時，用Sub()或Since()獲取Duration對象，再通過Seconds()、Minutes()、Hours()轉(zhuǎn)換為對應(yīng)單位；添
我如何根據(jù)語句使用語句執(zhí)行代碼？
Jun 23, 2025 pm 07:02 PM
Ingo，ifstatementSexecuteCodeBasedonConconditions.1.BasicsStructurerunsablockifaconditionistrue，例如IFX> 10 {...}。 2.Elseclausehan dlesfalseconditions，例如，else {...}。 3。 elseifchainsmultipleconditions，例如，elseifx == 10 {...}。 4.variableInitializationInsideIndifif，l
了解Web API的Golang和Python之間的性能差異
Jul 03, 2025 am 02:40 AM
Golangofferssuperiorperformance,nativeconcurrencyviagoroutines,andefficientresourceusage,makingitidealforhigh-traffic,low-latencyAPIs;2.Python,whileslowerduetointerpretationandtheGIL,provideseasierdevelopment,arichecosystem,andisbettersuitedforI/O-bo
去支持並發(fā)如何？
Jun 23, 2025 pm 12:37 PM
Gohandlesconcurrencyusinggoroutinesandchannels.1.GoroutinesarelightweightfunctionsmanagedbytheGoruntime,enablingthousandstorunco????ncurrentlywithminimalresourceuse.2.Channelsprovidesafecommunicationbetweengoroutines,allowingvaluestobesentandreceivedinas
如何使用lock（）和unlock（）方法來保護GO中的重要代碼部分？
Jun 23, 2025 pm 08:37 PM
在Go中保護臨界區(qū)的標(biāo)準(zhǔn)方法是使用sync.Mutex的Lock()和Unlock()方法。 1.聲明一個mutex並將其與要保護的數(shù)據(jù)一起使用；2.在進入臨界區(qū)前調(diào)用Lock()，確保只有一個goroutine能訪問共享資源；3.使用deferUnlock()確保鎖始終被釋放，避免死鎖；4.盡量縮短臨界區(qū)內(nèi)的操作以提高性能；5.對於讀多寫少的場景，應(yīng)使用sync.RWMutex，通過RLock()/RUnlock()進行讀操作，通過Lock()/Unlock()進行寫操作，從而提升並發(fā)效率。
