如何在Goroutine中获取返回值？同步调用协程并接收结果

你遇到的问题很典型——Go的go关键字启动goroutine时，语法上不允许直接接收其返回值，因为goroutine是异步执行的，调用语句不会等待它完成，编译器自然没法把返回值绑定到变量上。不过我们可以利用Go的核心并发原语「通道（channel）」来实现这个需求，让goroutine把结果传递给主goroutine。

具体实现步骤 #

首先，我们需要用通道来承载addItemSync的返回值，这里推荐定义一个简单的结构体来封装结果（比用两个单独通道更清晰）：

// 定义结构体封装函数的返回结果
type addItemResult struct {
    ok  bool
    err error
}

然后修改调用逻辑，把原函数放在匿名goroutine里执行，执行完成后将结果发送到通道，最后在主goroutine中接收结果：

// 创建一个用于传递结果的通道
resultChan := make(chan addItemResult)

// 启动goroutine执行函数
go func() {
    // 调用你的同步函数
    ok, err := s.addItemSync(ch, cs.ResponseQueue, user)
    // 将结果发送到通道
    resultChan <- addItemResult{ok: ok, err: err}
    // 发送完成后关闭通道（可选，单发送场景下不关闭也没问题，但属于好习惯）
    close(resultChan)
}()

// 从通道接收结果（这里会阻塞直到goroutine发送结果）
res := <-resultChan

// 后续的错误处理逻辑和你原来的需求一致
if !res.ok {
    if res.err != nil {
        log.Log.Error("Error adding channel", zap.Error(res.err))
        return
    }
}

额外说明 #

1. 为什么用结构体？：如果不想定义结构体，也可以用两个独立的通道（一个传bool，一个传error），但结构体能让结果的语义更清晰，避免通道之间的关联混乱。
2. 非阻塞接收？：如果你的场景不需要等待goroutine完成，可以用select语句配合通道实现非阻塞接收，避免主逻辑被阻塞。
3. 多个goroutine场景：如果要启动多个同类goroutine并收集结果，可以结合sync.WaitGroup和通道一起使用，确保所有goroutine都执行完成后再处理结果。

本质上，这是Go CSP（通信顺序进程）并发模型的体现——goroutine之间通过通道通信，而不是共享内存来传递状态。

内容的提问来源于stack exchange，提问作者lakeIn231