Golangchannel实现异步任务回调方法-Golang-PHP中文网

Golangchannel实现异步任务回调方法

P粉602998670

发布： 2025-09-22 14:36:01

原创

416人浏览过

使用channel模拟异步回调：启动goroutine执行任务，完成后通过channel发送结果，主协程接收数据实现回调处理。

golangchannel实现异步任务回调方法

在Go语言中，channel 是实现异步任务和回调机制的核心工具之一。虽然Go没有传统意义上的“回调函数”语法（如JavaScript），但通过 channel + goroutine 的组合，可以非常自然地实现异步任务执行与结果通知，达到类似回调的效果。

使用Channel模拟异步回调的基本模式

基本思路是：启动一个goroutine执行耗时任务，完成后通过channel将结果发送出去，主流程通过接收channel数据来“回调”处理结果。

示例代码：

func asyncTask(callback chan string) {
  go func() {
    // 模拟耗时操作
    time.Sleep(2 * time.Second)
    result := "任务完成"
    callback   }()
}

// 调用方式
resultCh := make(chan string, 1)
asyncTask(resultCh)
fmt.Println("任务已发起，继续其他工作...")

// 后续获取结果（可非阻塞或定时检查）
result := <-resultCh
fmt.Println("收到回调结果:", result)

带错误处理的回调封装

实际开发中，任务可能失败。建议使用结构体封装结果和错误，提升健壮性。

立即学习“go语言免费学习笔记（深入）”；

type TaskResult struct {
Data string
Err error
}

func asyncTaskWithError(callback chan TaskResult) {
  go func() {
    var result TaskResult
    if rand.Intn(2) == 0 {
      result = TaskResult{Data: "成功", Err: nil}
    } else {
      result = TaskResult{Data: "", Err: fmt.Errorf("任务失败")}
    }
    callback <- result
  }()
}

调用方根据 Err 字段判断是否成功，实现完整的回调逻辑。