首頁 > 後端開發 > Golang > 如何解決 Go 中「所有 goroutine 都在睡覺」的死鎖?

如何解決 Go 中「所有 goroutine 都在睡覺」的死鎖?

Mary-Kate Olsen
發布: 2024-12-24 16:11:10
原創
918 人瀏覽過

How to Solve the

處理Goroutine 中的死鎖:「所有Goroutine 都處於睡眠狀態」

理解死鎖

在提供的程式碼中,您會遇到因死鎖而導致的死鎖缺乏適當的渠道處理。問題出現在 UnloadTrucks 函數中,您無限期地阻塞等待卡車到達 ch 通道。然而,主協程永遠不會關閉這個通道,從而導致無休止的等待。

解決死鎖

要解決死鎖,必須在所有卡車裝載並發送後關閉 ch 通道通過通道。這可以透過使用 WaitGroup 來追蹤正在裝載卡車的 goroutine 來實現:

go func() {
    wg.Wait()
    close(ch)
}()
登入後複製

當所有 goroutine 完成裝載卡車時,通道 ch 將關閉,允許 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 {
        wg.Add(1)
        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])
    }

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

    fmt.Println("Done")
}
登入後複製

以上是如何解決 Go 中「所有 goroutine 都在睡覺」的死鎖?的詳細內容。更多資訊請關注PHP中文網其他相關文章!

來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
作者最新文章
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板