如何安全地從多個 Go 執行緒收集數據，同時防止競爭條件？

Go 中多執行緒的安全資料收集

在沒有適當同步的情況下跨多個執行緒並發存取共享資料可能會導致Go 中出現未定義的行為。這對於涉及讀寫操作的場景尤其重要。

並發訪問風險

在您的情況下，多個工作線程並行運行，而主線程定期尋求從這些工人那裡收集價值。如果不加以控制，可能會出現競爭條件，即多個執行緒嘗試同時存取相同的數據，從而可能會損壞資料。

同步選項

為了防止並發存取問題，您需要採用同步機制。一種常用的方法是通道，它促進 goroutine 之間的安全資料交換。但是，就您而言，通道可能不是最有效的選擇，因為您正在尋求從工作人員檢索數據，而不是讓他們主動發送數據。

互斥保護資料

更合適的解決方案涉及使用同步原語（例如sync.RWMutex）來保護共享資料結​​構。此鎖確保一次只有一個執行緒可以修改數據，同時允許多個執行緒同時存取資料進行讀取。

實作範例

這裡是一個簡化的實現，使用async.RWMutex:

type Worker struct {
    iterMu sync.RWMutex
    iter   int
}

func (w *Worker) Iter() int {
    w.iterMu.RLock()
    defer w.iterMu.RUnlock()
    return w.iter
}

func (w *Worker) setIter(n int) {
    w.iterMu.Lock()
    w.iter = n
    w.iterMu.Unlock()
}

在此範例中，worker 的Iter 方法取得讀鎖並返回當前迭代計數。 setIter 方法取得寫鎖，更新迭代計數，然後釋放鎖定。

或者，您可以使用sync/atomic 套件在整數計數器上提供原子操作，從而無需明確鎖定：

type Worker struct {
    iter int64
}

func (w *Worker) Iter() int64 {
    return atomic.LoadInt64(&w.iter)
}

func (w *Worker) setIter(n int64) {
    atomic.StoreInt64(&w.iter, n)
}

透過使用適當的同步技術，您可以安全地從Go 中的多個執行緒收集數據，確保資料完整性並防止競爭條件。

以上是如何安全地從多個 Go 執行緒收集數據，同時防止競爭條件？的詳細內容。更多資訊請關注PHP中文網其他相關文章！