在 go 中选择函数并发模式有四种选择：goroutine（独立任务）、通道（数据传递）、互斥量（同步访问）、等待组（等待完成）。选择模式的指南包括任务依赖关系、同步需求、等待完成需求。实战案例中，goroutine 用于并行打印数字，通道用于在 goroutine 之间传递数据。

在 Go 中选择函数并发编程模式

在 Go 中，函数并发编程提供了并行执行代码的有效方式。有四种函数并发模式可供选择：

• goroutine：单个并发函数，用于执行独立的任务。
• 通道：管道用于在 goroutine 之间传递数据。
• 互斥量：互斥量用于控制对共享资源的并发访问。
• 等待组：等待组用于等待多个 goroutine 完成其任务。

选择合适模式的指南

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

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

选择合适的模式取决于应用程序的具体需求。需要注意以下几点：

• 任务依赖关系：如果任务是独立的，则可以使用 goroutine。如果任务之间存在依赖关系，则需要考虑其他模式（例如通道）。
• 同步：如果需要同步对共享资源的访问，则需要使用互斥量。
• 等待完成：如果需要等待所有 goroutine 完成其任务，则可以使用等待组。

实战案例

使用 goroutine 并发打印数字

package main

import (
    "fmt"
    "runtime"
)

func main() {
    for i := 0; i < 10; i++ {
        go func(index int) {
            fmt.Printf("Goroutine %d\n", index)
        }(i)
    }

    // 确保所有 goroutine 在 main 函数返回之前完成
    runtime.Gosched()
}

使用通道在 goroutine 之间传递数据

package main

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup

    // 创建一个管道，用于在 goroutine 之间传递数据
    ch := make(chan int)

    for i := 0; i < 10; i++ {
        wg.Add(1)
        go func(index int, ch chan int) {
            defer wg.Done()

            // 向管道发送数据
            ch <- index
        }(i, ch)
    }

    // 从管道接收数据，总和并打印
    sum := 0
    for i := 0; i < 10; i++ {
        sum += <-ch
    }

    fmt.Printf("Sum: %d\n", sum)
    wg.Wait() // 等待所有 goroutine 完成
}