我正在嘗試識別或理解適用于我遇到的特定并發編程問題的技術、慣用語。為簡單起見，假設我有一個實時圖形用戶界面 (UI)，它始終以 10Hz 的頻率在屏幕上重繪。每當一組不同線程的至少一個實例正在運行時，我想在此 UI 上顯示一個“忙碌”指示器，并且我希望該指示器在這些線程中正好有 0 個正在運行時停止顯示。只要 UI 啟動，這些線程就可以隨時啟動和停止。我目前正在 golang 中實現這個（下面有相關的片段）。但總的來說，我按如下方式解決這個問題：通過 mutex 保護對計數器 int waitCount（請求我們指示“繁忙”的線程數）的R+W 訪問waitLock。功能drawStatus()：重繪整個 UI（每 100 毫秒發生一次）：繪制“忙碌”指示器獲取互斥體waitLock如果整數waitCount> 0：釋放互斥體waitLock功能startWait()：當一個線程需要指示忙碌時：獲取互斥體waitLock增量整數waitCount釋放互斥體waitLock功能stopWait()：當一個線程不再需要指示繁忙時：獲取互斥體waitLock遞減整數waitCount釋放互斥體waitLock對我來說，感覺我沒有充分利用 golang 的并發功能并訴諸于我熟悉的互斥體。但即便如此，此代碼中仍存在一個錯誤，其中“忙碌”指示器會過早消失。老實說，我不是在尋找任何人來幫助識別該錯誤，而是試圖傳達我感興趣的特定邏輯。是否有更慣用的 golang 方法來解決這個問題？或者是否有我應該研究的更通用的編程模式？我正在使用的這項技術有任何特定的名稱嗎？關于正確執行此操作的建議或指示會很棒。謝謝。
2 回答
qq_遁去的一_1
TA貢獻1725條經驗 獲得超8個贊
由于您所做的只是鎖定單個計數器，因此您可以簡化并僅使用sync/atomic包。AddInt32(&x, 1)在啟動 goroutine 和AddInt32(&x, -1)結束時調用。從您的繪圖 goroutine調用LoadInt32(&x)。
慕容708150
TA貢獻1831條經驗 獲得超4個贊
它依賴于用例（你可以選擇你想要的，并且在你產生錯誤或達到性能損失之前沒有人關心），通道將 Lock 隱藏在里面并使編碼更簡單，但性能成本很小 - 所以我建議使用通道對于一般用例，除非您正在考慮更高的性能）：
在以下情況下使用通道：
1 - 轉讓所有權
2 - 協調
在以下情況下使用基元：
3 -性能關鍵
4 - 保護結構
引用的內部狀態：第 33 頁
由于您使用的是協調 goroutine 數量的軟實時 UI，而不是性能關鍵代碼，因此我建議使用通道，我在此示例中簡化了您的代碼：
package main
import (
? ? "fmt"
? ? "math/rand"
? ? "time"
)
func main() {
? ? for i := 0; i < 100; i++ {
? ? ? ? go job() // e.g.: run all jobs
? ? }
? ? busy := 0
? ? time.Sleep(10 * time.Millisecond) // or make sure at least on goroutine started
? ? // 10Hz:
? ? tick := time.NewTicker(100 * time.Millisecond)
? ? defer tick.Stop()
? ? for {
? ? ? ? select {
? ? ? ? case n := <-ch:
? ? ? ? ? ? busy += n
? ? ? ? case <-tick.C:
? ? ? ? ? ? // forces the UI to redraw all changed screen regions
? ? ? ? ? ? fmt.Printf(" %d? ? \r", busy)
? ? ? ? ? ? if busy == 0 {
? ? ? ? ? ? ? ? return
? ? ? ? ? ? }
? ? ? ? }
? ? }
}
func job() {
? ? ch <- +1
? ? time.Sleep(time.Duration(rand.Intn(2000)) * time.Millisecond)
? ? ch <- -1
}
var ch = make(chan int, 1)
- 2 回答
- 0 關注
- 164 瀏覽
添加回答
舉報
0/150
提交
取消