如何解決非同步操作和空通道導致的Go死鎖？

Go 中的死鎖：「所有go 程式都在睡眠」

運行提供的程式碼時，由於其非同步執行模型而發生死鎖使用goroutine。在將任何卡車發送到通道之前調用 UnloadTrucks 函數時，就會出現問題。這會導致通道保持空狀態，導致發送者 goroutine 在 ch

解決方案：使用 WaitGroup 關閉通道

為了解決死鎖，我們可以在所有 goroutine 寄完卡車後關閉通道 ch。這可以透過引入WaitGroup 來實現，這是一個追蹤待處理goroutine 數量的同步原語：

go func() {
    wg.Wait()
    close(ch)
}()

此goroutine 會等待，直到所有其他goroutine 完成其任務（由Wait() 調用發出信號）。關閉通道。透過這樣做，UnloadTrucks 函數能夠在所有卡車發送完畢後正常退出。

修改後的代碼：

package main

import (
    "fmt"
    "sync"
    "time"
)

type Item struct {
    name string
}

type Truck struct {
    Cargo []Item
    name  string
}

func UnloadTrucks(c chan Truck) {

    for t := range c {
        fmt.Printf("%s has %d items in cargo: %s\n", t.name, len(t.Cargo), t.Cargo[0].name)
    }

}

func main() {
    trucks := make([]Truck, 2)

    ch := make(chan Truck)

    var wg sync.WaitGroup
    for i, _ := range trucks {

        trucks[i].name = fmt.Sprintf("Truck %d", i+1)

        fmt.Printf("Building %s\n", trucks[i].name)
    }

    for t := range trucks {
        go func(tr Truck) {

            itm := Item{}
            itm.name = "Groceries"

            fmt.Printf("Loading %s\n", tr.name)
            tr.Cargo = append(tr.Cargo, itm)
            ch <- tr
            wg.Done()

        }(trucks[t])
        wg.Add(1)
    }

    time.Sleep(50 * time.Millisecond)
    fmt.Println("Unloading Trucks")
    UnloadTrucks(ch)

    fmt.Println("Done")
}

使用此修改後的代碼，死鎖被消除是因為UnloadTrucks 函數保證在通道關閉之前接收到所有卡車。這可以確保所有 goroutine 正確完成其任務，並且程式運行不會出現任何意外中斷。

以上是如何解決非同步操作和空通道導致的Go死鎖？的詳細內容。更多資訊請關注PHP中文網其他相關文章！