简单实用：Go WaitGroup的应用实例分享-Golang-PHP中文网

简单实用：Go WaitGroup的应用实例分享

王林

发布： 2023-09-28 08:23:14

原创

650人浏览过

简单实用：go waitgroup的应用实例分享

简单实用：Go WaitGroup的应用实例分享

引言：
Go语言是一门并发编程语言，内置了许多并发处理的工具和特性。其中之一就是sync.WaitGroup，它提供了一种优雅且简单的方式来等待一组并发任务的完成。本文将分享一个具体的应用实例，展示了如何使用WaitGroup来加速并发任务的执行。

什么是WaitGroup？
sync.WaitGroup是Go语言标准库中的一个结构体，用于等待一组并发任务的完成。它内部维护了一个计数器，可以增加和减少计数器的值。当计数器的值变为0时，表示所有任务已经完成，WaitGroup内部的阻塞操作将解除。

应用实例：
假设我们有一个需求，需要从多个网页上爬取数据，并且要同时进行，以加快数据的获取速度。我们可以使用WaitGroup来并发地执行这些爬虫任务。下面是一个示例代码：

package main

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

func crawl(url string, wg *sync.WaitGroup) {
    defer wg.Done()

    resp, err := http.Get(url)
    if err != nil {
        fmt.Printf("发生错误：%s
", err)
        return
    }
    defer resp.Body.Close()

    body, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        fmt.Printf("发生错误：%s
", err)
        return
    }

    fmt.Printf("爬取完成：%s
", url)
    // TODO: 处理网页内容
}

func main() {
    urls := []string{
        "https://www.example.com",
        "https://www.google.com",
        "https://www.microsoft.com",
    }

    var wg sync.WaitGroup
    for _, url := range urls {
        wg.Add(1)
        go crawl(url, &wg)
    }

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

登录后复制

在上面的代码中，我们定义了一个crawl函数来执行单个爬虫任务。crawl函数接受一个URL和一个WaitGroup指针作为参数。在函数内部，我们使用http.Get发送HTTP请求，然后读取响应的内容。当任务完成后，我们调用wg.Done()来减少WaitGroup的计数器。

Metronic Bootstrap后台模板

Metronic是一套精美的响应式后台管理模板，基于强大的Twitter Bootstrap框架实现。Metronic拥有简洁优雅的Metro UI风格界面，自适应屏幕分辨率大小，兼容PC端和手机移动端。全套模板，包含仪表盘、侧边栏菜单、布局宣传片、电子邮件模板、UI特性、按钮、标签、表格布局、表单组件、多文件上传、悬浮窗文件上传、时间表、博客、新闻、关于我们、联系我们、日历、用户配置文件、锁屏、