闭包是 go 中允许函数访问外部变量的特性，在并发编程中很有用。通过闭包，协程可以安全共享数据和传值。闭包在并发编程中的常见应用包括：共享数据，无需同步机制。协程之间传值，即使值在闭包闭合后才可用。通过存储一个用于指示取消操作的通道来取消协程。
Go 语言函数闭包在并发编程中的应用
闭包是 Go 语言中强大的特性，它允许函数访问其作用域之外的变量。这种机制在并发编程中非常有用，因为它允许我们安全地共享数据并在协程之间传值。
基本原理
闭包是指一个函数及其包含作用域中所有变量的集合。在 Go 语言中，函数可以返回一个其他函数（闭包）的指针。这个闭包可以访问其父函数作用域中的所有变量，即使父函数已经返回。
例如，以下代码展示了一个简单的闭包：
立即学习“go语言免费学习笔记（深入）”；
func outer(x int) func() int {
// x 的值在这个闭包内部可用
return func() int {
return x
}
}outer 函数返回了一个闭包，该闭包访问并在返回函数调用时返回变量 x 的值。
并发编程中的应用
闭包在并发编程中非常有用，因为它允许在协程之间安全地共享和修改数据。以下是一些常见的用例：
- 共享数据：闭包可以在多个协程之间共享数据，而无需使用互斥锁或其他同步机制。
- 传值：闭包可以在协程之间传值，即使这些值在闭包闭合后才可用。
- 取消操作：闭包可以存储一个通道，该通道指示何时取消操作。这允许我们优雅地退出协程，并清理任何已分配的资源。
实战案例
考虑以下代码示例，它演示了闭包在并发编程中的使用：
package main
import (
"fmt"
"sync"
"time"
)
func main() {
// 创建一个要并发执行的任务列表
tasks := []func(){
func() { fmt.Println("Task 1") },
func() { fmt.Println("Task 2") },
func() { fmt.Println("Task 3") },
}
// 创建一个等待组以跟踪并发的任务
var wg sync.WaitGroup
wg.Add(len(tasks))
// 创建一个通道来取消操作
cancel := make(chan struct{})
// 为每个任务创建一个闭包
for _, task := range tasks {
go func(task func()) {
defer wg.Done()
select {
case <-cancel:
// 如果收到取消信号，则退出协程
return
default:
// 如果没有收到取消信号，则执行任务
task()
}
}(task)
}
// 等待所有任务完成
wg.Wait()
fmt.Println("All tasks completed")
// 发送取消信号以取消任何正在运行的协程
close(cancel)
}用法：
-
tasks列表包含要并发执行的任务。 -
wg跟踪并发任务的进度。 -
cancel通道用于向协程发送取消信号。 - 每个任务都通过闭包封装在自己的协程中。该闭包可以访问
cancel通道，以便在接收到取消信号时退出。 - 主协程使用
wg.Wait()等待所有任务完成。 - 一旦所有任务完成，主协程发送
cancel信号以取消任何剩余的协程。
在这个示例中，闭包被用来在协程之间安全地共享 cancel 通道，允许我们在需要时取消操作。
