Golang 同時プログラミングの上級者: WaitGroup についての深い理解

Golang 同時プログラミングの上級: WaitGroup についての深い理解

はじめに:
同時プログラミングは、Golang の最も強力な機能の 1 つです。複数のタスクを並行して実行する場合、一般的なシナリオは、すべてのタスクが完了するまで待ってから次のステップに進むことです。 Golang の同期パッケージは、この問題を解決する優れたツール WaitGroup を提供します。この記事では、WaitGroup の使用方法を詳しく紹介し、具体的なコード例を示します。

1. WaitGroup とは何ですか?
WaitGroup は Golang の同期パッケージの構造体であり、すべての goroutine がタスクを完了するのを待つためのシンプルで効果的なメカニズムを提供します。 WaitGroup は内部的にカウンターを維持します。カウンターの値は Add() メソッドによって増やすことができ、カウンターの値は Done() メソッドによって減らすことができ、Wait() メソッドは現在のスレッドをブロックするために使用されます。カウンタはゼロに戻ります。

2. WaitGroup の基本的な使用法
まず、同期パッケージをインポートする必要があります:

import "sync"

次に、次の手順に従って WaitGroup を使用します:

1. WaitGroup オブジェクトを作成します:

   var wg sync.WaitGroup

   ログイン後にコピー

2. Add() メソッドを使用して待機するタスクの数を設定します:

   wg.Add(2)

   ログイン後にコピー

3. ゴルーチンを開始してタスクを実行します:

   go task1()
   go task2()

   ログイン後にコピー

4. タスクが終了する前に Done() メソッドを呼び出してカウンター値を減らします:

   func task1() {
    defer wg.Done()
    // 执行task1的操作
   }
   
   func task2() {
    defer wg.Done()
    // 执行task2的操作
   }

   ログイン後にコピー

5. 最後に、すべてのタスクが完了するのを待つ必要がある場所で Wait() メソッドを呼び出します。

   wg.Wait()

   ログイン後にコピー

   このようにして、メイン スレッドは、次のステップに進む前にすべてのタスクが完了するのを待ちます。

3. WaitGroup の実用的なアプリケーション例
以下では、WaitGroup の使用法を説明するために具体的な例を使用します。

複数のネットワーク イメージを同時にダウンロードし、ローカルに保存するという要件があるとします。すべての画像がダウンロードされたら、後続の処理を実行する必要があります。コード例は次のとおりです。

package main

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

var wg sync.WaitGroup

func main() {
    // 假设有3个图片需要下载
    imageUrls := []string{
        "https://example.com/image1.jpg",
        "https://example.com/image2.jpg",
        "https://example.com/image3.jpg",
    }

    // 设置需要等待的任务数量
    wg.Add(len(imageUrls))

    // 并发下载图片
    for _, imageUrl := range imageUrls {
        go downloadImage(imageUrl)
    }

    // 等待所有任务完成
    wg.Wait()

    fmt.Println("所有图片下载完成，进行后续处理")
}

func downloadImage(imageUrl string) {
    defer wg.Done()

    // 发送HTTP GET请求获取图片数据
    resp, err := http.Get(imageUrl)
    if err != nil {
        fmt.Printf("下载图片失败: %v
", err)
        return
    }
    defer resp.Body.Close()

    // 创建本地文件
    fileName := imageUrl[strings.LastIndex(imageUrl, "/")+1:]
    imgFile, err := os.Create(fileName)
    if err != nil {
        fmt.Printf("创建图片文件失败: %v
", err)
        return
    }
    defer imgFile.Close()

    // 将图片数据保存到本地文件
    _, err = io.Copy(imgFile, resp.Body)
    if err != nil {
        fmt.Printf("保存图片失败: %v
", err)
        return
    }

    fmt.Printf("图片下载成功: %v
", imageUrl)
}

上記のコード例では、まず、タスクの完了を待機するカウンターを管理するためにパッケージ レベルの変数 wg を定義します。 main 関数では、待機タスクの数を画像 URL の数に設定し、各画像ダウンロード タスクを同時に開始します。各タスクが完了したら、wg.Done() メソッドを呼び出してカウンター値をデクリメントします。最後に、wg.Wait() メソッドを呼び出して、すべてのタスクが完了するのを待ちます。すべての画像がダウンロードされたら、以降の処理を続けます。

概要:
この記事では、Golang での WaitGroup の使用方法を詳細に紹介し、画像のマルチタスク同時ダウンロードの具体的な例を示します。 WaitGroup の使用法を深く理解することで、Golang の同時プログラミング機能をよりよく習得し、プログラムのパフォーマンスと効率を向上させることができます。実際のアプリケーションでは、WaitGroup を柔軟に使用して、特定のニーズに応じて複数のゴルーチンを管理し、完了を待つことができます。

以上がGolang 同時プログラミングの上級者: WaitGroup についての深い理解の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。