Go の「select」ステートメントでのチェーンされたチャネル操作はどのようにしてデッドロックやデータ損失を引き起こすのでしょうか?

単一の select ケースでのチャネル操作の連鎖: 潜在的な落とし穴の分析

Go では、select ステートメントは複数を多重化する便利な方法を提供します。チャンネル。次のシナリオを考えてみましょう。A と B という 2 つのチャネルがあり、異なる間隔でメッセージを送信します。 A と B の両方からメッセージを受信するファンイン チャネルを作成したいと考えています。

以下のコードはこれを示しています。

func fanIn(input1, input2 <-chan string) <-chan string {
    ch := make(chan string)
    go func() {
        for {
            select {
                case t := <-input1:
                    ch <- t
                case t := <-input2:
                    ch <- t
            }
        }
    }()

    return ch
}

このコードを実行すると、メッセージを受信することが期待されます。両方のチャネルからインターリーブ方式で送信されます。ただし、select case ステートメントを次のように変更すると、予期しない動作が発生します。

func fanIn(input1, input2 <-chan string) <-chan string {
    ch := make(chan string)
    go func() {
        for {
            select {
                case ch <- <-input1:
                case ch <- <-input2:
            }
        }
    }()

    return ch
}

この場合、いくつかのメッセージは正しく受信されますが、値が削除され、最終的にはデッドロックが発生します。この動作の理由は、select の基本的な動作にあります。

select では、1 つのチャネルの読み取りまたは書き込み操作のみがノンブロッキングです。他のすべての操作は通常どおりに動作します。修正されたコードでは、両方のケースにノンブロッキングのチャネル書き込みが含まれています。これにより、入力チャネルからのメッセージがキューに入る状況が発生しますが、ファンイン チャネルは一度に 1 つしか消費できません。

その結果、メッセージがドロップされ、ファンイン時にデッドロックが発生する可能性があります。チャネルにはライターが存在せず、リーダーは追加の値を待機しています。

この問題を回避するには、select ステートメントでは 1 つの操作のみが非ブロックである必要があることを理解することが重要です。単一の選択ケースで複数のチャネル操作を実行する必要がある場合は、次のような非ブロッキング選択ヘルパー関数の使用を検討してください:

func nonBlockingSelect(cases []reflect.SelectCase) (chosen int, recv interface{}, ok bool) {
    for i, c := range cases {
        if c.Dir == reflect.SelectSend && c.Chan == nil {
            continue
        }
        v, ok := reflect.Select(cases)
        return v.Index, v.Elem().Interface(), ok
    }

    return -1, nil, false
}

その後、変更されたファンイン関数は次のように書き換えることができます:

func fanIn(input1, input2 <-chan string) <-chan string {
    ch := make(chan string)
    go func() {
        for {
            select {
                case c1 := <-input1:
                    nonBlockingSelect([]reflect.SelectCase{
                        {Dir: reflect.SelectSend, Chan: reflect.ValueOf(ch), Send: reflect.ValueOf(c1)},
                    })
                case c2 := <-input2:
                    nonBlockingSelect([]reflect.SelectCase{
                        {Dir: reflect.SelectSend, Chan: reflect.ValueOf(ch), Send: reflect.ValueOf(c2)},
                    })
            }
        }
    }()

    return ch
}

ノンブロッキング選択ヘルパーを使用すると、1 つのチャネル操作のみがノンブロッキングとなり、値のドロップの問題が防止され、デッドロック。

以上がGo の「select」ステートメントでのチェーンされたチャネル操作はどのようにしてデッドロックやデータ損失を引き起こすのでしょうか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。