登录
首页 >  Golang >  Go教程

Golang 函数如何进行并发处理

时间:2024-10-26 09:47:53 167浏览 收藏

本篇文章给大家分享《Golang 函数如何进行并发处理》,覆盖了Golang的常见基础知识,其实一个语言的全部知识点一篇文章是不可能说完的,但希望通过这些问题,让读者对自己的掌握程度有一定的认识(B 数),从而弥补自己的不足,更好的掌握它。

Go 函数中使用 Goroutine 实现并发处理:创建 Goroutine:使用 go 关键字和函数调用。通道通信:使用通道在 Goroutine 之间安全地发送和接收数据。等待 Goroutine 完成:使用 sync.WaitGroup 类型等待 Goroutine 组运行完毕。

Golang 函数如何进行并发处理

Go 函数并发处理指南

Go 语言中的 Goroutine 提供了一种轻量级且高性能的并发处理机制。本文将介绍如何在 Go 函数中使用 Goroutine 进行并发处理,并通过实战案例予以说明。

创建 Goroutine

要创建 Goroutine,可以使用 go 关键字,后接一个函数调用。如下例所示:

go func() {
  // Goroutine 代码
}

通道通信

Goroutine 之间需要通信时,可以使用通道。通道允许 Goroutine 安全地发送和接收数据。如下例所示:

channel := make(chan string)
go func() {
  channel <- "Hello, world!"
}()

// 从通道接收数据
message := <-channel

等待 Goroutine 完成

在需要等待 Goroutine 完成时,可以使用 sync.WaitGroup 类型。WaitGroup 允许 Go 程序等待一组 Goroutine 运行完毕。如下例所示:

var wg sync.WaitGroup
wg.Add(1)
go func() {
  // 完成任务
  wg.Done()
}()

// 等待 Goroutine 完成
wg.Wait()

实战案例:并发爬虫

以下实战案例演示了如何使用 Goroutine 构建一个简单的并发爬虫:

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

func main() {
    // 创建通道
    results := make(chan string)

    // 创建 WaitGroup
    var wg sync.WaitGroup

    // 创建 10 个 Goroutine
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(i int) {
            // 发送结果到通道
            defer wg.Done()
            fmt.Printf("Goroutine %d: Fetching url\n", i)
            result, err := http.Get("https://www.example.com")
            if err != nil {
                fmt.Printf("Error fetching url: %s\n", err)
                return
            }

            // 结果类型定义为字符串
            results <- fmt.Sprintf("Goroutine %d: Status code: %d", i, result.StatusCode)
        }(i)
    }

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

    // 关闭通道
    close(results)

    // 打印结果
    for result := range results {
        fmt.Println(result)
    }
}

在该案例中,Goroutine 并发地从指定 URL 抓取内容,并通过通道将其状态代码发送回主 Goroutine。主 Goroutine 等待所有 Goroutine 完成,然后打印结果。

文中关于golang,并发处理的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《Golang 函数如何进行并发处理》文章吧,也可关注golang学习网公众号了解相关技术文章。

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>