异步回调 API 的同步化封装器

今天golang学习网给大家带来了《异步回调 API 的同步化封装器》，其中涉及到的知识点包括等等，无论你是小白还是老手，都适合看一看哦~有好的建议也欢迎大家在评论留言，若是看完有所收获，也希望大家能多多点赞支持呀！一起加油学习~

我在项目中使用 pion/webrtc go 库，发现这个问题是该库提供的基于回调的 api（反映了 webrtc 的 javascript api）在 go 中使用起来很尴尬。

例如，执行以下操作

conn.ontrack(func(...) { ... })
conn.oniceconnectionstatechange(func(...) { ... })

在 javascript 中是典型的，但在 go 中，这有一些问题：

• 如果并行调用回调，则此 api 可以轻松引入数据竞争。
• 基于回调的 api 会传播到代码库的其他部分，并使所有内容都接受回调。

go 中处理这种情况的传统方法是什么？我是 go 新手，我读到同步 api 在 go 中是首选，因为 goroutines 很便宜。因此，也许一种可能的设计是使用通道来同步回调：

msgChan := make(chan Msg)
// or use a separate channel for each type of event?

conn.OnTrack(func(...) {
  msgChan <- onTrackMsg
})
conn.OnICEConnectionStateChange(func(...) {
  msgChan <- onStateChangeMsg
})

for {
  msg := <-msgChan
  // do something depending on the type of msg
}

我认为强制与通道同步基本上模仿了 javascript 的单线程特性。

无论如何，人们通常如何在 go 中建模事件驱动的工作流程？

解决方案

不需要频道。只需将异步/回调代码包装在等待响应的单个函数中，并使用 waitgroup（您可以在此处使用通道，但 waitgroup 更容​​易）：

func DoSomething() (someType, error) {
    var result SomeType
    var err error
    wg := sync.WaitGroup{}
    wg.Add(1)
    StartAsyncProcess(func() {
        // This is the call back that gets called eventually
        defer wg.Done()
        result = /* Set the result */
        err = /* and/or set the error */
    })
    wg.Wait() // Wait until the callback is called, and exits
    return result, err  // And finally return our values
}

如果您的回调依赖于或修改共享状态，您可能需要/希望在回调中添加额外的锁或同步（如果您的情况有必要）。

以上就是《异步回调 API 的同步化封装器》的详细内容，更多关于的资料请关注golang学习网公众号！