小编Rog*_*lin的帖子

go concurrency 所有 goroutine 都睡着了 - 死锁

很抱歉这个菜鸟问题,但我很难把头放在 go 的并发部分。基本上,下面的这个程序是我正在编写的一个更大的程序的简化版本,因此我想保持类似于下面的结构。

基本上,我想addCount(..)使用无缓冲通道并发运行而不是等待 4 秒,并且当 中的所有元素int_slice都被处理后,我想对它们进行另一个操作。然而,这个程序以“恐慌:关闭通道关闭”结束,如果我取消关闭通道,我会得到我期待的输出,但它会恐慌:“致命错误:所有 goroutines 都睡着了 - 死锁”

在这种情况下如何正确实现并发部分?

提前致谢!

package main

import (
    "fmt"
    "time"
)

func addCount(num int, counter chan<- int) {
    time.Sleep(time.Second * 2)
    counter <- num * 2
}

func main() {
    counter := make(chan int)
    int_slice := []int{2, 4}

    for _, item := range int_slice {
        go addCount(item, counter)
        close(counter)
    }

    for item := range counter {
        fmt.Println(item)
    }
}
Run Code Online (Sandbox Code Playgroud)

concurrency go

3
推荐指数
1
解决办法
2755
查看次数

标签 统计

concurrency ×1

go ×1