如何在 golang 中并发执行函数回调？使用 go 关键字创建 goroutine。在 goroutine 中调用要执行的回调函数。回调函数可以在管道中并发传回结果。
如何在 Golang 中并发执行函数回调
在 Golang 中，您可以使用 goroutine 并发执行函数回调。这是一种轻量级的线程，允许您在后台执行任务，而不会阻塞主线程。
使用 Goroutine 并发执行回调
为了使用 goroutine 并发执行回调，您可以使用 go 关键字：
func main() {
// 定义要执行的回调
callback := func(arg string) {
fmt.Println("回调已执行：", arg)
}
// 启用 goroutine 并发执行回调
go callback("参数")
}上面代码将启动一个 goroutine 来执行 callback 函数。函数将打印 "回调已执行：参数"，然后继续执行主程序。
立即学习“go语言免费学习笔记（深入）”；
实战案例：并在管道中并发传回结果
使用 goroutine 的另一个常见用例是在管道中并发传回结果。管道是一个用于在并发程序之间通信的通道。
package main
import (
"fmt"
"sync"
"time"
)
func main() {
// 创建一个管道
resultCh := make(chan int)
// 定义要执行的回调
callback := func(arg string, resultCh chan<- int) {
// 模拟一个耗时的任务
time.Sleep(100 * time.Millisecond)
fmt.Println("回调已执行：", arg)
// 将结果发送到管道
resultCh <- 1
}
wg := sync.WaitGroup{}
// 启用 goroutine 并发执行回调
for i := 0; i < 5; i++ {
wg.Add(1)
go func(i int) {
defer wg.Done()
callback(fmt.Sprintf("参数 %d", i), resultCh)
}(i)
}
go func() {
wg.Wait()
close(resultCh)
}()
// 从管道中读取结果
for result := range resultCh {
fmt.Println("收到的结果：", result)
}
}在上面的例子中，我们将 callback 函数的结果发送到管道 resultCh。主程序从管道中读取这些结果并将其打印到控制台上。这允许我们并发执行回调并以异步方式收集结果。
