natsClient.Subscribe("some_subject", some_callback)：Golang中'some_callback'是否在自己的Goroutine中运行？

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《natsClient.Subscribe("some_subject", some_callback)：Golang中'some_callback'是否在自己的Goroutine中运行？》，这篇文章主要讲到等等知识，如果你对Golang相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

基本上就是主题所说的内容。我有兴趣知道每次调用回调方法时，golang 的 nats-lib 是否会确保回调将在其自己的 goroutine 上运行（我 99% 确信它会运行，但我需要确保，因为我可以在 nats 中找不到任何明确的文档来明确说明这一点 - 如果我遗漏了某些内容，请随意复制粘贴任何链接）。

如果回调确实在它自己的 goroutine 中运行，我也有兴趣知道是否：

a.每次特定订阅都使用相同的 goroutine

或b.每次触发回调都会创建一个临时 goroutine：在这种情况下，回调完成工作后 goroutine 就会被释放

正确答案

当你调用 conn.subscribe("some_subject", somecallback) 时，如果定义了回调，它会执行这段代码：

// If we have an async callback, start up a sub specific
    // Go routine to deliver the messages.
    if cb != nil {
        sub.typ = AsyncSubscription
        sub.pCond = sync.NewCond(&sub.mu)
        go nc.waitForMsgs(sub)
    }

它为创建的订阅启动一个 goroutine。当消息到达时，它会执行 waitformsgs goroutine 中定义的回调。

简而言之，答案是a.，它每次都使用相同的goroutine来进行特定的订阅。

终于介绍完啦！小伙伴们，这篇关于《natsClient.Subscribe("some_subject", some_callback)：Golang中'some_callback'是否在自己的Goroutine中运行？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！