Golang 函数中 goroutine 的创建和管理-Golang-PHP中文网

Golang 函数中 goroutine 的创建和管理

WBOY

发布： 2024-05-23 15:48:02

原创

509人浏览过

go语言中，创建goroutine使用go关键字加函数调用。管理goroutine时，使用sync.waitgroup进行同步；使用context包可取消goroutine。实战中可用于并行处理网络请求、图片处理等任务。

Golang 函数中 goroutine 的创建和管理

Goroutine（协程）是 Go 语言中的轻量级并行执行单元，可以在单个线程中同时并发运行多个任务。

创建 Goroutine

创建一个 goroutine 非常简单，可以使用 go 关键字后跟一个函数调用即可：

func hello() {
    fmt.Println("Hello from goroutine")
}

func main() {
    go hello() // 创建一个执行 hello() 函数的 goroutine
}

登录后复制

Goroutine 管理

同步

在处理共享资源时，需要对 goroutine 进行同步。使用 sync.WaitGroup 可以等待一组 goroutine 完成：

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

JTopCms建站系统

JTopCMS基于JavaEE自主研发，是用于管理站群内容的国产开源软件(CMS)，能高效便捷地进行内容采编，审核，模板制作，用户交互以及文件等资源的维护。安全，稳定，易扩展，支持国产中间件及数据库，适合建设政府，教育以及企事业单位的站群系统。系统特色 1. 基于 JAVA 标准自主研发，支持主流国产信创环境，国产数据库以及国产中间件。安全，稳定，经过多次政务与企事业单位项目长期检验，顺利通过

查看详情

var wg sync.WaitGroup

func hello(name string) {
    wg.Add(1)
    defer wg.Done()

    fmt.Println("Hello", name)
}

func main() {
    wg.Add(3)
    go hello("John")
    go hello("Mary")
    go hello("Bob")
    wg.Wait() // 等待所有 goroutine 完成
}

登录后复制

取消

可以使用 context 包取消 goroutine：

import (
    "context"
    "fmt"
    "time"
)

func heavyComputation(ctx context.Context) {
    for {
        select {
        case <-ctx.Done():
            fmt.Println("Computation cancelled")
            return
        default:
            // 执行计算
        }
    }
}

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    go heavyComputation(ctx)
    time.Sleep(10 * time.Second) // 10 秒后取消计算
}

登录后复制

实战案例

并行处理网络请求：

func main() {
    urls := []string{"https://example.com", "https://example.net", "https://example.org"}

    var wg sync.WaitGroup

    for _, url := range urls {
        wg.Add(1)
        go func(url string) {
            resp, err := http.Get(url)
            if err != nil {
                log.Fatal(err)
            }

            resp.Body.Close()
            wg.Done()
        }(url)
    }

    wg.Wait()
}

登录后复制

并行处理图片处理：

func main() {
    images := []string{"image1.jpg", "image2.jpg", "image3.jpg"}

    var wg sync.WaitGroup

    for _, image := range images {
        wg.Add(1)
        go func(image string) {
            img, err := image.Decode(image)
            if err != nil {
                log.Fatal(err)
            }

            // 处理图像

            wg.Done()
        }(image)
    }

    wg.Wait()
}

登录后复制

以上就是Golang 函数中 goroutine 的创建和管理的详细内容，更多请关注php中文网其它相关文章！