ホームページ > バックエンド開発 > Golang > Go の「すべてのゴルーチンがスリープ状態」デッドロックを解決する方法?

Go の「すべてのゴルーチンがスリープ状態」デッドロックを解決する方法?

Mary-Kate Olsen
リリース: 2024-12-24 16:11:10
オリジナル
918 人が閲覧しました

How to Solve the

ゴルーチンのデッドロックへの対処: 「すべてのゴルーチンがスリープ状態である」

デッドロックについて

提供されたコードでは、デッドロックが発生します。適切なチャネル処理が行われていないことが原因です。問題は UnloadTrucks 関数で発生し、ch チャネルにトラックが到着するのを無期限にブロックすることになります。ただし、メインの goroutine はこのチャネルを決して閉じないため、無限の待機が発生します。

デッドロックへの対処

デッドロックを解決するには、すべてのトラックがロードされて送信された後に ch チャネルを閉じる必要があります。チャンネルを通して。これは、WaitGroup を使用して、トラックをロードしているゴルーチンを追跡することで実現できます。

go func() {
    wg.Wait()
    close(ch)
}()
ログイン後にコピー

すべてのゴルーチンがトラックのロードを完了すると、チャネル 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 の「すべてのゴルーチンがスリープ状態」デッドロックを解決する方法?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
著者別の最新記事
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート