如何在 Golang 并发编程中使用匿名函数?
go协程中使用匿名函数可提升代码可读性和简化性。匿名函数可用作协程函数或回调函数,可以用于以下两种主要操作:作为协程函数,直接用于协程。作为回调函数,传递给其他函数。
Go 协程中使用匿名函数
匿名函数(也称为 lambda 表达式)允许您在不声明 named 函数的情况下定义函数。它在 Go 并发编程中很有用,因为它可以帮助简化代码并提高可读性。
语法
在 Go 中,匿名函数的语法如下:
func(参数列表) 返回值类型 { 函数体 }
使用
有两种主要方法可以在 Go 协程中使用匿名函数:
- 作为协程函数:匿名函数可以用作协程的函数。例如:
go func() { // 协程代码 }()
- 作为回调函数:匿名函数可以作为回调函数传递给其他函数。例如:
func RunInParallel(f func()) { go f() } RunInParallel(func() { // 并行运行的代码 })
实战案例
以下是一个实战案例,展示了如何在 Go 并发编程中使用匿名函数:
package main import ( "fmt" "math/rand" "sync" "time" ) func main() { const numWorkers = 5 results := make(chan int) wg := &sync.WaitGroup{} // 创建一个工作池 for i := 0; i < numWorkers; i++ { go func(id int) { defer wg.Done() // 模拟一些工作 time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond) // 将结果发送到通道 results <- id }(i) } wg.Add(numWorkers) close(results) // 从结果通道接收结果 for result := range results { fmt.Printf("Result from worker %d\n", result) } }
在这个示例中,我们创建了一个带有 5 个工作者的工作池。每个工作者作为匿名函数运行,模拟一些工作并向通道发送结果。主 goroutine 等待所有工作者完成并接收并打印结果。