登录
首页 >  Golang >  Go问答

使用缓冲通道处理Go中的错误时,监听和服务时的最佳实践

来源:stackoverflow

时间:2024-03-21 21:42:39 484浏览 收藏

在 Go 中处理错误时,监听和服务时使用缓冲通道是一种最佳实践。通过创建一个缓冲通道,即使没有接收者接收错误,也能确保错误被写入,从而避免了 goroutine 阻塞。缓冲通道(大小为 1)允许写入操作不会阻塞发送方 goroutine,使其能够继续执行并返回。而无缓冲通道则保证了消息的传递,但可能会延迟。因此,使用缓冲通道可以确保错误的交付,同时避免 goroutine 阻塞,即使没有客户端调用者从错误通道读取。

问题内容

我正在学习有关使用 go 构建 web 服务器的教程。

作者没有直接使用 http.listenandserve() 方法,而是创建了 http.server 结构体。

然后他继续:

  • 创建一个缓冲通道来侦听错误

    servererrors := make(chan errors, 1)
    
  • 生成绑定到该通道的 http 监听 goroutine

    go func(){
        fmt.Println("starting...")
        serverErrors <- api.ListenAndServe()
    }()
    

使用缓冲通道的原因是根据讲师的说法

这样如果我们不收集这个错误,goroutine 就可以退出

下面的程序中确实有一个 select 块,其中正在收集来自该通道的错误。

谁能帮我理解如果我们不收集错误,goroutine 如何退出?

如果我们使用无缓冲通道,实际差异是什么?


解决方案


简短回答:

对于任何通道(无论是否缓冲),如果没有任何内容写入通道,则通道读取会阻塞。

对于非缓冲通道,如果没有人在监听,通道写入将会阻塞。

这是一种常见的错误通道技术(因为只有一个项目会被写入通道),使其成为大小为 1 的缓冲通道。它确保写入不会阻塞 - 并且 writer goroutine 可以继续前行并返回。

因此,服务不依赖客户端调用者从错误通道读取来执行清理。

注意:要回收一个通道以进行 gc,它只需超出范围即可 - 不需要完全耗尽。也不需要关闭。一旦它超出了两端的范围,就会被 gc 回收。

如果您参考 listenandserve() 的代码,您会注意到以下关于其工作原理的注释。引用自那里:

另外,

您的 select 块正在等待 shutdown (错误),因为您正在正常处理服务器的关闭,并且在正常关闭之前不会让 goroutine 退出。

对于 func (srv *server) close() (例如,大多数使用 defer srv.close(),对吗?)

因此,使用 select 块的解释与上面相同。

现在,让我们将通道分类为 bufferedunbuffered,如果我们确实关心信号传送的保证(与通道的通信),那么无缓冲通道可以确保这一点。然而,如果您的情况是缓冲通道(大小 = 1),那么它可以确保交付,但可能会延迟。

让我们详细说明一下 unbuffered 通道

a send operation on an unbuffered channel blocks the sending goroutine until another 
goroutine executes a corresponding receive on that same channel, at which point the value 
is transmitted and both goroutines may continue

conversely, if received on the channel earlier (<-chan) than send operation, then the 
receiving goroutine is blocked until the corresponding send operation occurs on the 
same channel on another goroutine.

请记住,func main() 也是一个 goroutine。

让我们详细说明一下 缓冲通道

A send operation on a buffered channel pushes an element at the back of the queue, 
and a receive operation pops an element from the front of the queue. 
 1. If the channel is full, the send operation blocks its goroutine until space is made available by another goroutine's receive. 
 2. If the channel is empty, a receive operation blocks until a value is sent by another goroutine.

因此,为了阻止发送者 goroutine,使用了 select block。从引用的代码的文档中,您可以看到

另外,为了更清楚,您可以参考:Behaviour of channels 作者解释得很清楚。

文中关于的知识介绍,希望对你的学习有所帮助!若是受益匪浅,那就动动鼠标收藏这篇《使用缓冲通道处理Go中的错误时,监听和服务时的最佳实践》文章吧,也可关注golang学习网公众号了解相关技术文章。

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>