Go 関數(shù)での効率的な並列タスク処理: 同時ルーチンを起動するには go キーワードを使用します。 sync.WaitGroup を使用して、未処理のルーチンの數(shù)をカウントします。ルーチンが完了すると、wg.Done() が呼び出されてカウンターがデクリメントされます。メイン プログラムは、すべてのルーチンが完了するまで wg.Wait() の使用をブロックします。実際のケース: Web リクエストを同時に送信し、応答を収集します。

Go 関數(shù)での効率的な並列タスク処理

Go 言語は強力な並列処理機能を提供し、開発者が簡単に作成して実行できるようにします。同時タスクを獨立して実行できます。この記事では、Go 関數(shù)を使用して並列タスクを効率的に処理する方法について説明し、その使用法を示す実踐的なケースを示します。

Go 関數(shù)の同時実行性

Go 関數(shù)には、同時実行をサポートする 2 つのキーワード go と sync.WaitGroup が用意されています。 。 go キーワードは同時 Go ルーチンを開始するために使用され、sync.WaitGroup はすべてのルーチンが完了するのを待つために使用されます。

Wait Group

sync.WaitGroup は、未処理のルーチンの數(shù)を追跡するために使用されるカウンターです。ルーチンが完了すると、wg.Done() を呼び出してカウンターをデクリメントします。メイン プログラムは、wg.Wait() メソッドを使用して、すべてのルーチンが完了するまでブロックできます。

実踐的なケース: 同時 Web リクエスト

複數(shù)の Web リクエストを同時に送信し、応答を収集する必要があるシナリオを考えてみましょう。以下は、Go 関數(shù)を使用して効率的な同時タスク処理を行う方法を示すコードです:

package main

import (
    "fmt"
    "net/http"
    "sync"
)

func main() {
    // 要發(fā)送的 Web 請求 URL
    urls := []string{"https://example.com", "https://example2.com", "https://example3.com"}

    // 創(chuàng)建等待組
    var wg sync.WaitGroup

    for _, url := range urls {
        // 啟動一個并發(fā)例程來發(fā)送 Web 請求
        wg.Add(1)
        go func(url string) {
            // 發(fā)送 GET 請求
            resp, err := http.Get(url)
            if err != nil {
                fmt.Printf("Error getting %s: %v\n", url, err)
            } else {
                fmt.Printf("Status code for %s: %d\n", url, resp.StatusCode)
            }

            // 例程完成，遞減等待組計數(shù)
            wg.Done()
        }(url)
    }

    // 等待所有例程完成
    wg.Wait()
}

上記のコード:

• sync.WaitGroup を使用して、 track 未処理のルーチンの數(shù)。
• Web リクエスト URL ごとに、同時 Go ルーチンを開始してリクエストを送信します。
• ルーチンは wg.Done() を使用して、完了したことを示します。
• メイン プログラムは wg.Wait() を使用して、すべてのルーチンが完了するまでブロックします。

この方法を使用すると、複數(shù)の Web リクエストを同時に送信し、各リクエストの応答を待たずにメイン プログラムの実行を続けることができます。

以上がGolang 関數(shù)が並列タスクを効率的に処理する方法の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。