在 go 中选择函数并发模式有四种选择:goroutine(独立任务)、通道(数据传递)、互斥量(同步访问)、等待组(等待完成)。选择模式的指南包括任务依赖关系、同步需求、等待完成需求。实战案例中,goroutine 用于并行打印数字,通道用于在 goroutine 之间传递数据。
在 Go 中选择函数并发编程模式
在 Go 中,函数并发编程提供了并行执行代码的有效方式。有四种函数并发模式可供选择:
- goroutine:单个并发函数,用于执行独立的任务。
- 通道:管道用于在 goroutine 之间传递数据。
- 互斥量:互斥量用于控制对共享资源的并发访问。
- 等待组:等待组用于等待多个 goroutine 完成其任务。
选择合适模式的指南
立即学习“go语言免费学习笔记(深入)”;
选择合适的模式取决于应用程序的具体需求。需要注意以下几点:
- 任务依赖关系:如果任务是独立的,则可以使用 goroutine。如果任务之间存在依赖关系,则需要考虑其他模式(例如通道)。
- 同步:如果需要同步对共享资源的访问,则需要使用互斥量。
- 等待完成:如果需要等待所有 goroutine 完成其任务,则可以使用等待组。
实战案例
使用 goroutine 并发打印数字
package main
import (
"fmt"
"runtime"
)
func main() {
for i := 0; i < 10; i++ {
go func(index int) {
fmt.Printf("Goroutine %dn", 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: %dn", sum)
wg.Wait() // 等待所有 goroutine 完成
}