GolangWaitGroup实现并发任务同步示例-Golang-PHP中文网

GolangWaitGroup实现并发任务同步示例

P粉602998670

发布： 2025-09-26 20:19:01

原创

970人浏览过

WaitGroup用于等待多个goroutine完成，通过Add增加计数、Done减少计数、Wait阻塞直至归零，示例中并发下载网页并等待全部完成，需注意Add与Done配对、避免提前Wait及在goroutine内调用Done。

golangwaitgroup实现并发任务同步示例

在Go语言中，WaitGroup 是 sync 包提供的一个同步原语，用于等待一组并发的 goroutine 完成任务。它非常适合用于主协程需要等待多个子协程执行完毕后再继续的场景。

WaitGroup 基本用法

WaitGroup 有三个核心方法：

Add(n int)：增加计数器，表示要等待的 goroutine 数量
Done()：减少计数器，通常在 goroutine 结束时调用
Wait()：阻塞主协程，直到计数器归零

下面是一个使用 WaitGroup 实现并发任务同步的简单示例：

并发下载多个网页

假设我们要并发地从多个 URL 下载内容，并等待所有下载完成：

芦笋演示

一键出成片的录屏演示软件，专为制作产品演示、教学课程和使用教程而设计。

查看详情

立即学习“go语言免费学习笔记（深入）”；

package main

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

func fetch(url string, wg *sync.WaitGroup) {
    defer wg.Done() // 任务完成，计数器减1

    fmt.Printf("开始获取: %s\n", url)
    resp, err := http.Get(url)
    if err != nil {
        fmt.Printf("请求失败 %s: %v\n", url, err)
        return
    }
    defer resp.Body.Close()

    body, _ := ioutil.ReadAll(resp.Body)
    fmt.Printf("成功获取 %s，响应长度: %d\n", url, len(body))
}

func main() {
    urls := []string{
        "https://httpbin.org/delay/1",
        "https://httpbin.org/status/200",
        "https://httpbin.org/headers",
    }

    var wg sync.WaitGroup

    for _, url := range urls {
        wg.Add(1)           // 每启动一个 goroutine，计数加1
        go fetch(url, &wg)  // 并发执行
    }

    wg.Wait() // 等待所有任务完成
    fmt.Println("所有任务已完成")
}

登录后复制