go - 所有 channel 都陷入僵局

coder 2023-06-27 原文

我正在尝试使用一个 for 循环，它不断地将字符串发送到由不同的 goroutine 读取的不同 channel 。但是，它给了我错误“所有 goroutines 都睡着了 - 死锁!”为什么会这样？我搜索了一些答案，但找不到针对这种情况的答案。

func main() {
    var chans []chan string

    for i := 0; i < 3; i++ {
        chans = append(chans, make(chan string))
    }

    for i := 0; i < 3; i++ {
        go sendString(chans[i])
    }

    for str := range chans[0] {
        fmt.Print(str)
    }
}

func sendString(ch chan string) {
    ch <- "a"
    ch <- "b"
    ch <- "c"
    ch <- "d"
}

错误在这里。它打印“abcd”，然后生成错误，如果我删除打印循环，程序不会生成错误。

abcdfatal error: all goroutines are asleep - deadlock!

 goroutine 1 [chan receive]:
main.main()
    C:/Users/YuanZheng Hu/Desktop/Go Test/test/test.go:18 +0x28d

goroutine 19 [chan send]:
main.sendString(0xc04203c120)
    C:/Users/YuanZheng Hu/Desktop/Go Test/test/test.go:24 +0x42
created by main.main
    C:/Users/YuanZheng Hu/Desktop/Go Test/test/test.go:15 +0x175

goroutine 20 [chan send]:
main.sendString(0xc04203c180)
    C:/Users/YuanZheng Hu/Desktop/Go Test/test/test.go:24 +0x42
created by main.main
    C:/Users/YuanZheng Hu/Desktop/Go Test/test/test.go:15 +0x175
exit status 2

我使用 WaitGroup 做了这个版本，但它似乎不正确，并且给了我同样的错误“所有 goroutines 都睡着了 - 死锁!”我在下面的代码中哪里做错了？

func main() {
var myWaitGroup sync.WaitGroup
ch := make(chan string)
myWaitGroup.Add(1)
go sendString(ch, &myWaitGroup)


myWaitGroup.Wait()
close(ch)

time.Sleep(1 * time.Second)
}
func sendString(ch chan string, pg *sync.WaitGroup) {
ch <- "a"
ch <- "b"
ch <- "c"
ch <- "d"
defer pg.Done()

}

最佳答案

第二个 for 循环将阻塞，直到 channel 关闭，因此您需要在发送函数中关闭它。此外，您只从第一个 channel 读取，因此一些数据丢失了。这样做:

func main() {
    var chans []chan string

    for i := 0; i < 3; i++ {
        chans = append(chans, make(chan string))
    }

    for i := 0; i < 3; i++ {
        go sendString(chans[i])
    }

    for i := 0; i < 3; i++ {
        for str := range chans[i] {
            fmt.Print(str)
        }
    }

}
func sendString(ch chan string) {
    ch <- "a"
    ch <- "b"
    ch <- "c"
    ch <- "d"
    close(ch)
}

将产生:

abcdabcdabcd

https://play.golang.org/p/7SoDKChnTbz

如果您想按照您的评论对单个 channel 执行此操作，那么您可以添加一个 WaitGroup 以在所有 go 例程完成后关闭 channel :

func main() {
    c := make(chan string)
    var wg sync.WaitGroup

    for i := 0; i < 3; i++ {
        wg.Add(1)
        go func() {
            sendString(c)
            wg.Done()
        }()
    }

    go func() {
        wg.Wait()
        close(c)
    }()

    for str := range c {
        fmt.Print(str)
    }

}
func sendString(ch chan string) {
    ch <- "a"
    ch <- "b"
    ch <- "c"
    ch <- "d"
}

https://play.golang.org/p/E_awt8UBK9v

关于go - 所有 channel 都陷入僵局，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/49766629/

陷入僵局僵局 sendString 34 chan go channel

有关go - 所有 channel 都陷入僵局的更多相关文章

ruby - 如何以所有可能的方式将字符串拆分为长度最多为 3 的连续子字符串？ - 2
我试图获取一个长度在1到10之间的字符串，并输出将字符串分解为大小为1、2或3的连续子字符串的所有可能方式。例如:输入:123456将整数分割成单个字符，然后继续查找组合。该代码将返回以下所有数组。[1,2,3,4,5,6][12,3,4,5,6][1,23,4,5,6][1,2,34,5,6][1,2,3,45,6][1,2,3,4,56][12,34,5,6][12,3,45,6][12,3,4,56][1,23,45,6][1,2,34,56][1,23,4,56][12,34,56][123,4,5,6][1,234,5,6][1,2,345,6][1,2,3,456][123
ruby-on-rails - 跳过状态机方法的所有验证 - 2
当我的预订模型通过rake任务在状态机上转换时，我试图找出如何跳过对ActiveRecord对象的特定实例的验证。我想在reservation.close时跳过所有验证!叫做。希望调用reservation.close!(:validate=>false)之类的东西。仅供引用，我们正在使用https://github.com/pluginaweek/state_machine用于状态机。这是我的预订模型的示例。classReservation["requested","negotiating","approved"])}state_machine:initial=>'requested
ruby - Nokogiri 剥离所有属性 - 2
我有这个html标记:我想得到这个:我如何使用Nokogiri做到这一点？最佳答案 require'nokogiri'doc=Nokogiri::HTML('')您可以通过xpath删除所有属性:doc.xpath('//@*').remove或者，如果您需要做一些更复杂的事情，有时使用以下方法遍历所有元素会更容易:doc.traversedo|node|node.keys.eachdo|attribute|node.deleteattributeendend 关于ruby-Nokog
ruby - 获取模块中定义的所有常量的值 - 2
我想获取模块中定义的所有常量的值:moduleLettersA='apple'.freezeB='boy'.freezeendconstants给了我常量的名字:Letters.constants(false)#=>[:A,:B]如何获取它们的值的数组，即["apple","boy"]？最佳答案为了做到这一点，请使用mapLetters.constants(false).map&Letters.method(:const_get)这将返回["a","b"]第二种方式:Letters.constants(false).map{|c
ruby - 如何遍历 Ruby 中所有正则表达式匹配的字符串？ - 2
我们有一个字符串:“”这个正则表达式://i如何从当前字符串中获取所有匹配项？最佳答案 "".scan(//)参见scan在ruby-docs上关于ruby-如何遍历Ruby中所有正则表达式匹配的字符串？，我们在StackOverflow上找到一个类似的问题： https://stackoverflow.com/questions/6857852/
ruby-on-rails - 在所有延迟的作业之前 Hook - 2
是否可以在所有delayed_job任务之前运行一个方法？基本上，我们试图确保每个运行delayed_job的服务器都有我们代码的最新实例，所以我们想运行一个方法来在每个作业运行之前检查它。(我们已经有了“check”方法并在别处使用它。问题只是关于如何从delayed_job中调用它。) 最佳答案现在有一种官方方法可以通过插件来做到这一点。这篇博文通过示例清楚地描述了如何执行此操作http://www.salsify.com/blog/delayed-jobs-callbacks-and-hooks-in-rails(本文中描述
ruby - 如何捕获 ruby 中的所有异常？ - 2
我们如何捕获或/和处理ruby中所有未处理的异常？例如，这样做的动机可能是将某种异常记录到不同的文件或发送电子邮件给系统管理。在Java中我们会做Thread.setDefaultUncaughtExceptionHandler(UncaughtExceptionHandlerex);在Node.js中process.on('uncaughtException',function(error){/*code*/});在PHP中register_shutdown_function('errorHandler');functionerrorHandler(){$error=error_
ruby - 递归地将所有数字字符串转换为 Ruby 哈希中的整数 - 2
我有一个随机大小的散列，它可能有类似"100"的值，我想将其转换为整数。我知道我可以使用value.to_iifvalue.to_i.to_s==value来做到这一点，但我不确定我将如何在我的散列中递归地做到这一点，考虑到一个值可以是一个字符串，或一个数组(哈希或字符串)，或另一个哈希。最佳答案这是一个非常简单的递归实现(尽管必须同时处理数组和散列会增加一些技巧)。deffixnumifyobjifobj.respond_to?:to_i#IfwecancastittoaFixnum,doit.obj.to_ielsifobj
ruby - 如何捕获所有 HTTP 流量(本地代理) - 2
我希望访问我机器上的所有HTTP流量(我的Windows机器-不是服务器)。据我了解，拥有一个本地代理是所有流量路线的必经之路。我一直在谷歌搜索但未能找到任何资源(关于Ruby)来帮助我。非常感谢任何提示或链接。最佳答案 WEBrick中有一个HTTP代理(Rubystdlib的一部分)和here's一个实现示例。如果你喜欢生活在边缘，还有em-proxy伊利亚·格里戈里克。这postIlya暗示它似乎确实需要一些调整来解决您的问题。关于ruby-如何捕获所有HTTP流量(本地代理)
ruby - 我可以使用 RVM 为所有用户维护单一版本的 Ruby 吗？ - 2
我喜欢RVM。我意识到它的主要用例是让不同的用户在不同版本的Ruby之间切换。但是假设我正在将Rails应用程序部署到服务器，并且我只想运行单个版本的Ruby。特别是，我想要1.9.2，用RVM安装它很容易，但没有它就很痛苦。有没有一种方法可以让我说“我希望这是所有用户的规范Ruby安装”(连同它的所有gem)，而不必手动创建一堆符号链接(symboliclink)并在每次更新到更新时更改它们Ruby版本？最佳答案以root身份安装RVM并执行sudorvmuse1.9.2--default。任何采购/usr/local/rvm

go - 所有 channel 都陷入僵局

有关go - 所有 channel 都陷入僵局的更多相关文章

随机推荐