Golang チャネルのブロッキングおよび非ブロッキングメカニズムの分析-Golang-php.cn

Golang チャネルのブロッキングおよび非ブロッキングメカニズムの分析

WBOY

リリース： 2023-08-08 11:13:19

オリジナル

1408 人が閲覧しました

Golang Channels 的阻塞和非阻塞机制解析

Golang チャネルのブロッキングメカニズムと非ブロッキングメカニズムの分析

はじめに:
Channels は、Golang の重要な同時通信メカニズムの 1 つであり、さまざまな Goroutine の通信を可能にします。そしてそれらの間で同期します。チャネルを使用すると、ブロッキング状況と非ブロッキング状況がよく発生します。この記事では、チャネルのブロッキングおよび非ブロッキングのメカニズムを紹介し、コード例を通じてその原理と使用法を説明します。

ブロッキングとノンブロッキングの基本概念
同時プログラミングでは、ブロッキングとノンブロッキングは 2 つの一般的な処理方法です。簡単に言うと、ブロッキングとは、ゴルーチンがチャネルの読み取りまたは書き込みを試行したときに、チャネルの準備ができていない場合、チャネルの準備ができるまでゴルーチンはブロックされることを意味し、非ブロッキングとは、ゴルーチンが準備ができているかどうかに関係なく、ゴルーチンが準備ができていないことを意味します。チャネルの準備ができています。この場合、実行はすぐに続行されます。

Golang では、チャネルの長さを使用する方法と select ステートメントを使用する方法の 2 つの方法で、ブロッキングメカニズムとノンブロッキングメカニズムを実装できます。以下、一つずつご紹介していきます。

チャネルの長さを使用してブロッキングと非ブロッキングを実現します
バッファリングされていないチャネルの場合、その長さは 0 です。 Goroutine がバッファリングされていない Channel にデータを書き込もうとするとき、同じ Channel で読み取りを待機している他の Goroutine が存在しない場合、Goroutine がデータを読み取る準備ができるまで書き込み操作はブロックされます。同様に、Goroutine がバッファリングされていない Channel からデータを読み取ろうとする場合、同じ Channel への書き込みを待機している他の Goroutine が存在しない場合、読み取り操作はブロックされます。

コード例:

package main

import "fmt"

func main() {
    ch := make(chan int) // 创建一个无缓冲 Channel

    go func() {
        fmt.Println("开始写入数据")
        ch <- 1 // 写入数据到 Channel
        fmt.Println("数据写入成功")
    }()

    fmt.Println("等待读取数据")
    data := <-ch // 从 Channel 读取数据
    fmt.Println("读取到数据：", data)
}

ログイン後にコピー

上記のコードでは、バッファリングされていないチャネル ch を作成します。 main 関数では、チャネル ch にデータを書き込むゴルーチンを開始します。メインのゴルーチンでは、チャネル ch からデータを読み取ろうとしますが、このチャネルへの書き込みを待機している他のゴルーチンがないため、読み取り操作はブロックされます。読み取り操作は、データを書き込んだゴルーチンの実行が終了するまで続行されません。

select ステートメントを使用してノンブロッキングを実現する
チャネルの長さを使用してブロッキングとノンブロッキングを実現することに加えて、Golang には select ステートメントも用意されており、これにより同時通信をより多く処理できるようになります。柔軟に。

select ステートメントでは、複数のチャネルの読み取りおよび書き込み操作を同時に監視できます。 1 つ以上のチャネルの準備ができたら、select ステートメントは実行可能な操作をランダムに選択して実行します。準備ができているチャネルがない場合、少なくとも 1 つのチャネルが準備できるまで、select ステートメントはブロック状態になります。

コード例:

package main

import "fmt"

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)

    go func() {
        ch1 <- 1
    }()

    go func() {
        ch2 <- 2
    }()

    fmt.Println("开始监听 Channel")
    select {
    case data := <-ch1:
        fmt.Println("从 ch1 中读取到数据：", data)
    case data := <-ch2:
        fmt.Println("从 ch2 中读取到数据：", data)
    }
}

ログイン後にコピー

上記のコードでは、2 つのチャネル ch1 と ch2 を作成し、それぞれ 2 つのゴルーチンを開始しました。それぞれ 2 つのチャンネル。メインのゴルーチンでは、select ステートメントを使用して、複数のチャネルから実行可能なオペレーションを選択します。両方のチャネルの準備が完了しているため、select ステートメントは実行可能な操作の 1 つをランダムに選択して実行します。

結論:
この記事の導入とコード例を通じて、Golang チャネルのブロッキングメカニズムと非ブロッキングメカニズムについて学びました。実際の開発では、さまざまなニーズやシナリオに応じて適切な方法を選択する必要があります。 Channel の長さを使用するか、select ステートメントを使用するかにかかわらず、Golang の同時通信メカニズムは柔軟で効率的な同時処理機能を提供できます。並行プログラムを作成するときは、ブロックメカニズムと非ブロックメカニズムを深く理解し、プログラムの正確さとパフォーマンスを確保するために適切な処理方法を合理的に選択する必要があります。

参考資料: