golang関数を使用して並行プログラミングを実装する方法

Go 言語関数は、コルーチンを作成し、チャネルを利用することで同時プログラミングを実装します。コルーチンは、go キーワードを使用して作成された軽量のスレッドです。チャネルは、コルーチン間でデータを転送するためのパイプです。プロデューサー コルーチンはデータの送信に 演算子を使用します。次の例は、ワーカー関数が入力値を 2 乗し、ワーカー チャネルと結果チャネルを介してコルーチン間通信を実装する、データの並列処理の実際的なケースを示しています。

#Go 言語の関数による同時プログラミングの実装

Go 言語では、関数によって同時プログラミングを実装するための強力なツールが提供されます。並行関数を作成および管理することで、効率的でスケーラブルなアプリケーションを簡単に作成できます。

コルーチン

Go 言語のコルーチンは、メイン プログラムのメモリ空間を共有する軽量のスレッドです。コルーチン間の切り替えコストは低いため、並列タスクの実行に最適です。

コルーチンを作成するには、

go キーワードを使用できます。

go func() {
  // 并发执行的代码
}

各コルーチンは並行して実行され、メイン プログラムや他のコルーチンの影響を受けません。

Channel

Channel は、コルーチン間でデータを転送するパイプです。データは、

chan キーワードを使用して宣言されます。例:

ch := make(chan int)

プロデューサー コルーチンは、

演算子を使用してチャネルからデータを送信できます:

ch <- 1

コンシューマ コルーチンは、

-> 演算子を使用してチャネルからデータを受信できます:

val := <-ch

実際のケース: データの並列処理

次の例は、使用方法 この関数は、データを並列処理します。

package main

import (
    "fmt"
    "sync"
)

// 工作函数
func worker(in <-chan int, out chan<- int, wg *sync.WaitGroup) {
    defer wg.Done()
    
    for v := range in {
        v *= v
        out <- v
    }
}

func main() {
    // 创建工作通道和结果通道
    in := make(chan int)
    out := make(chan int)
    
    // 创建工作池
    var wg sync.WaitGroup
    for i := 0; i < 4; i++ {
        wg.Add(1)
        go worker(in, out, &wg)
    }
    
    // 向工作通道中发送数据
    for i := 0; i < 1000; i++ {
        in <- i
    }
    
    // 关闭工作通道
    close(in)
    
    // 从结果通道中接收数据
    for v := range out {
        fmt.Printf("%d ", v)
    }
    
    // 等待所有工作完成
    wg.Wait()
}

この場合、

worker 関数は、各入力値を 2 乗してデータを処理します。 4 つのコルーチンを含むワーカー プールを作成します。メイン プログラムは作業チャネルにデータを送信し、コルーチンはチャネルからデータを受信して​​タスクを並列処理します。最後に、メイン プログラムは結果チャネルから処理されたデータを受け取ります。

以上がgolang関数を使用して並行プログラミングを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。