如何在 Golang 中并发执行函数回调

如何在 golang 中并发执行函数回调？使用 go 关键字创建 goroutine。在 goroutine 中调用要执行的回调函数。回调函数可以在管道中并发传回结果。

如何在 Golang 中并发执行函数回调

在 Golang 中，您可以使用 goroutine 并发执行函数回调。这是一种轻量级的线程，允许您在后台执行任务，而不会阻塞主线程。

使用 Goroutine 并发执行回调

为了使用 goroutine 并发执行回调，您可以使用 go 关键字：

func main() {
    // 定义要执行的回调
    callback := func(arg string) {
        fmt.Println("回调已执行：", arg)
    }

    // 启用 goroutine 并发执行回调
    go callback("参数")
}

上面代码将启动一个 goroutine 来执行 callback 函数。函数将打印 "回调已执行：参数"，然后继续执行主程序。

实战案例：并在管道中并发传回结果

使用 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。主程序从管道中读取这些结果并将其打印到控制台上。这允许我们并发执行回调并以异步方式收集结果。

以上就是如何在 Golang 中并发执行函数回调的详细内容，更多请关注其它相关文章！