golangでパイプを適切に閉じる方法-Golang-php.cn

golangでパイプを適切に閉じる方法

PHPz

リリース： 2023-04-06 10:48:29

オリジナル

1196 人が閲覧しました

Golang のパイプラインは、異なる Goroutine 間でデータを受け渡し、データ競合を回避できる非常に強力なデータ構造です。ただし、パイプを扱うときの一般的な疑問は、デッドロックや漏れを防ぐためにパイプを適切に閉じる方法です。

この記事では、一般的な問題を回避するために Go でパイプを適切に閉じる方法を紹介します。

パイプを閉じる操作

Go のパイプは、組み込みの close() 関数を通じて閉じることができます。 close() 関数の操作は 1 回限りの操作です。つまり、パイプを閉じた後は、それ以上データをパイプに書き込むことはできません。

例:

ch := make(chan int)
close(ch)

ログイン後にコピー

パイプが閉じているかどうかを確認するにはどうすればよいですか?

パイプの別の戻り値を使用して、パイプが閉じられているかどうかを判断できます。この値はbool型の変数で、パイプが閉じている場合はtrue、閉じていない場合はfalseとなります。

例:

ch := make(chan int)
go func() {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch)
}()
for x := range ch {
    fmt.Println(x)
}

ログイン後にコピー

この例では、整数型のパイプ ch を作成し、別のゴルーチンの ch にデータを書き込みます。 main 関数では、range ステートメントを使用してパイプ内のデータを読み取ります。パイプが閉じられると、range ステートメントはループを停止します。

追加の変数を使用して、パイプが閉じているかどうかを判断することもできます。

ch := make(chan int)
go func() {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    close(ch)
}()
for {
    x, ok := <-ch
    if !ok {
        break
    }
    fmt.Println(x)
}

ログイン後にコピー

この例では、パイプからデータを読み取るたびに、後続のブール戻り値 ok もチェックします。 ok の値が false の場合、パイプラインは閉じられています。

パイプを安全に閉じるにはどうすればよいですか?

パイプラインを使用する場合、プログラムのデッドロックやリークを防ぐために、特定の状態でパイプラインを閉じる必要がある場合があります。たとえば、複数のゴルーチン間で共有されるパイプラインでは、他のすべてのゴルーチンが終了した後に 1 つのゴルーチンがパイプラインを安全に閉じる必要がある場合があります。

現時点では、追加の Goroutine を使用して、パイプが安全に閉じられているかどうかを検出できます。この検出ゴルーチンはパイプラインに通知信号を送信でき、他のすべてのゴルーチンが終了するとパイプラインを閉じることができます。

例:

ch := make(chan int)
done := make(chan bool)

go func() {
    for i := 0; i < 5; i++ {
        ch <- i
    }
    done <- true
}()

go func() {
    <-done
    close(ch)
}()

for x := range ch {
    fmt.Println(x)
}

ログイン後にコピー

この例では、done パイプを使用してシャットダウンコルーチンに通知します。最初のゴルーチンはパイプにデータを書き込み、すべてのデータが書き込まれると、done パイプに true シグナルを送信します。 2 番目のゴルーチンは、done パイプで信号を受信した後、パイプ ch を閉じます。