这个匿名函数中的 go 例程是如何运行的？

该匿名 go 例程创建了一个新的 goroutine，该 goroutine 将消息发送到通道中，然后立即返回。由于 goroutine 在单独的执行“线程”中运行，因此不会阻塞当前函数调用。如果通道中没有内容可读取，则 goroutine 将阻塞，直到有内容被读取为止。这允许在后台发送消息，而不会影响当前函数的执行。

func (s *server) send(m *message) error {
    go func() {
        s.outgoingMessageChan <- message
    }()
    return nil
}

func main(s *server) {
    for {
        select {
        case <-someChannel:
            // do something
        case msg := <-s.outGoingMessageChan:
            // take message sent from "send" and do something
        }
    }
}

我在另一个函数中从这个 s.outgoingmessagechan 中取出，在使用匿名 go 函数之前，对此函数的调用通常会阻塞 - 这意味着每当调用 s.outgoingmessagechan <-message 时， s.outgoingmessagechan <-message 都会阻塞，直到有东西被拉动出来了。不过这样包裹起来之后，似乎就不再阻塞了。我知道它会将此操作发送到后台并照常进行，但我无法理解这如何不影响当前的函数调用。

解决方案

每次调用 send 时都会创建一个新的 goroutine，并立即返回。 （顺便说一句，如果永远不会出现错误，则没有理由返回错误。）如果没有任何内容可以从 chan 中读取（假设它是无缓冲的），则 goroutine（它有自己的执行“线程”）将阻塞。一旦从 chan 读取消息，goroutine 将继续，但由于它不执行任何其他操作，因此它只会结束。

我应该指出，不存在“匿名 goroutine”这样的东西。 goroutines 根本没有标识符（除了一个仅用于调试目的的数字）。您有一个匿名函数，您将 go 关键字放在前面，使其在单独的 goroutine 中运行。

对于像您想要的那样阻塞的发送函数，只需使用：

func (s *server) send(m *message) {
    s.outgoingMessageChan <- message
}

但是，我看不出这个函数有任何意义（尽管它是内联的，并且与不使用函数一样有效）。

我怀疑您可能在从 chan 读取任何内容之前多次调用 send。在这种情况下，将会创建许多新的 goroutine（每次调用 send 时），它们都会被阻塞。每次从一个 goroutine 中读取 chan 时，都会解除阻塞传递其值，并且该 goroutine 将终止。这样做只是创建了一个低效的缓冲机制。此外，如果长时间调用 send 且其速度快于从 chan 读取值的速度，那么最终将耗尽内存。更好的方法是使用缓冲的 chan（并且没有 goroutine），一旦它（chan）完全对产生消息的任何内容施加“背压”。

另一点是函数名 main 用于标识程序的入口点。请为上面的第二个函数使用另一个名称。它似乎也应该是一种方法（使用 s *server 接收器）而不是函数。

今天关于《这个匿名函数中的 go 例程是如何运行的？》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！