登录
首页 >  Golang >  Go问答

为什么没有出现接收器被阻塞的错误?

来源:stackoverflow

时间:2024-03-17 16:57:27 193浏览 收藏

Go语言中,接收操作通常会阻塞,直到有数据可接收。然而,在特定情况下,接收操作可能不会阻塞,这是因为接收方没有被阻塞。当一个goroutine尝试从一个没有人准备发送数据的通道接收数据时,这种情况就会发生。这并不是错误,而是通道作为同步工具的一种正常用例。通过向主goroutine添加一个延迟函数,可以观察到剩余的goroutine数量,从而了解有多少goroutine被阻塞。

问题内容

根据 go 文档:

接收器总是阻塞,直到有数据要接收

此测试应该失败,因为对于来自通道的最后一个接收操作,没有相应的写入:

package main

import "fmt"

func main() {
    c := make(chan int)    
    for i := 0; i < 4; i++ { // 4 async reads
      go func() {
            fmt.println("received:", <-c)
         }()

    }    
    // just 3 writes, 1 write is missing
    c <- 1   
    c <- 2 
    c <- 3   
}

但是脚本在 read goroutine 中并没有失败并显示错误消息,而是成功打印了 3 个值:

received: 1
received: 2
received: 3

为什么会这样,或者我误解了同步的某些内容?


解决方案


这里没有死锁,因为 main goroutine 没有被阻塞。它在 c 上发送 3 个值,这些值成功,因为有 4 个已启动的 goroutines 从它接收,然后结束。并且它也会结束你的应用程序,它不会等待其他非 main goroutine 结束。请参阅No output from goroutine

死锁意味着所有 goroutine 都被阻塞。这里的情况并非如此。

尝试从没有人(当前或曾经)准备发送的通道接收数据并不是错误。如果事实上的话,那是完全正常的。这是通道的用例之一:它充当同步工具,您可以发送/接收,并且操作将阻塞,直到另一端也准备好为止。

在某些情况下,即使 goroutine 在整个应用程序生命周期内被阻塞也是正常的,例如goroutine 可能会等待用户输入,例如 ctrl+break,用户可能永远不会按下这些输入,并且应用程序可能会正常结束。

因此这不被视为错误,并且不会打印任何错误或警告消息。但如果你好奇的话,实现它很容易。只需向您的 main() 添加一个延迟函数,该函数将在您的 main() 函数(以及您的应用程序)结束之前最后调用。在该打印中运行的 goroutine 数量:

func main() {
    defer func() {
        fmt.println("remaining goroutines:", runtime.numgoroutine()-1) //-1 for main
    }()

    // your code
}

添加此内容后,输出将是:

received: 1
received: 2
received: 3
Remaining goroutines: 1

如果您将循环更改为启动 14 个 goroutine 而不是 1 个,则输出将显示剩余 11 个 goroutine。

最后一点:由于在您的应用程序中, main() 函数不会等待其他 goroutine 结束,因此在调用延迟函数时它们可能仍然处于活动状态,因此它们可能会或可能不会包含在剩余的 goroutine 中goroutine 计数。如果您想使用例如sync.waitgroup 等待它们结束,那么它们肯定不会被包含在内。有关示例,请参阅 Prevent the main() function from terminating before goroutines finish in Golang

今天关于《为什么没有出现接收器被阻塞的错误?》的内容介绍就到此结束,如果有什么疑问或者建议,可以在golang学习网公众号下多多回复交流;文中若有不正之处,也希望回复留言以告知!

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