是否可以延迟 goroutine？

Question

是否有可能在 go 中推迟一个 go 例程，或者一种实现所需行为的方法？以下背景：我正在将连接汇集到一个通道中的数据库。基本上在我调用的处理程序中

session, err := getSessionFromQueue()
// ...
// serving content to my client
// ...
go queueSession(session)

我真正想做的是：

session, err := getSessionFromQueue()
defer go queueSession(session)
// ...
// serving content to my client
// ...

以避免我的处理程序在某些时候是 hanging/crashing 并且会话未正确返回到队列。我想运行它作为 go 例程的原因是 queueSession 可能会阻塞 1 秒（如果队列已满，我会等待一秒钟，然后再完全关闭会话）。

更新

@abhink 让我走上了正确的轨道。我通过在 queueBackend.

中调用 goroutine 解决了这个问题

func queueSession(mongoServer *Server) {
    go func(mongoServer *Server) {
        select {
        case mongoQueue <- mongoServer:
            // mongoServer stored in queue, done.
        case <- time.After(1 * time.Second):
            // cannot queue for whatever reason after 1 second
            // abort
            mongoServer.Close()
        }
    }(mongoServer)
}

现在我可以简单地调用

defer queueSession(session)

它是运行作为 goroutine。

Answer 1

没有办法直接defer一个goroutine。你可以尝试这样的事情：

session, err := getSessionFromQueue()
defer func() {
    go queueSession(session)
}()

是否可以延迟 goroutine？

Is it possible to defer a goroutine?

go

goroutine

deferred