go - 是否可以推迟goroutine？

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
// ...

为了避免我的处理程序在某个时刻挂起/崩溃并且 session 没有正确返回到队列中。我想将其作为go例程运行的原因是queueSession可能会阻塞1秒钟(如果队列已满，我将等待一秒钟再完全关闭 session )。

更新

@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运行。

最佳答案

无法直接对goroutine进行defer编码。您可以尝试如下操作:

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

MongoServer

go - 是否可以推迟goroutine？