有可能推迟一个goroutine吗?

jbose2ul  于 2023-09-28  发布在  Go
关注(0)|答案(1)|浏览(88)

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

以避免我的处理程序在某个时候挂起/崩溃,并且会话没有正确返回到队列。我想把它作为一个go例程运行的原因是queueSession可能会阻塞1秒(如果队列已满,我会在完全关闭会话之前等待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运行的。

fwzugrvs

fwzugrvs1#

没有办法直接defer一个goroutine。你可以试试这样的方法:

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

相关问题