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

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

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

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)
    }
}