golang 中的函数并发编程可通过创建协程实现,使用 sync.waitgroup 同步机制确保主协程等待所有子协程执行完成,由此协调多个独立任务同时运行。
在 Golang 中实现函数并发编程
并发编程简介
并发编程是一种编程范例,它允许程序中的多个独立部分同时执行。这可以通过创建多个协程(轻量级线程)来实现,每个协程都可以独立运行。
立即学习“go语言免费学习笔记(深入)”;
Golang 中的协程
Golang 中的协程是通过 go 关键字创建的。go 关键字创建一个新的协程,该协程会并行于当前协程运行。协程可以在任何函数中创建。
以下是创建协程的示例:
func main() {
go sayHello()
}
func sayHello() {
fmt.Println("Hello, world!")
}
上述示例将创建一个新的协程来执行 sayHello() 函数,同时主协程继续执行。
函数并发编程实战
函数并发编程可以通过使用 sync.WaitGroup 来实现,sync.WaitGroup 是一种同步机制,它允许主协程等待所有子协程完成执行。
以下是使用 sync.WaitGroup 实现函数并发编程的示例:
package main
import (
"fmt"
"sync"
)
func main() {
var wg sync.WaitGroup
// 创建 10 个协程
for i := 0; i < 10; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
fmt.Printf("协程 %d 正在执行n", i)
}(i)
}
// 等待所有协程完成
wg.Wait()
fmt.Println("所有协程已完成")
}
在这个示例中,我们创建了 10 个协程,每个协程代表一个任务。sync.WaitGroup 用于跟踪尚未完成的任务数。主协程在等待所有协程完成之前不会继续执行。