解决 goroutines 死锁

对于一个Golang开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《解决 goroutines 死锁》，主要介绍了golang，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

问题内容

我一直在尝试解决我在 Golang 并发中遇到的这个简单问题。我一直在寻找所有可能的解决方案，但没有发现任何特定于我的问题（或者我可能会错过一个）。这是我的代码：

package main

import (
    "fmt"
    "time"
)

func producer(ch chan int, d time.Duration, num int) {

    for i:=0; i
它打印错误：

致命错误：所有 goroutine 都处于休眠状态 - 死锁！
goroutine 1 [chan 接收]: main.main() D:/Code/go/src/testconcurrency/main.go:23
+0xca 退出状态 2

避免此错误的有效方法是什么？，谢谢。

    正确答案

您需要同步 goroutine 中的所有异步进程。您的主线程和 goroutine 线程不是同步进程。您的主线程永远不会知道何时停止从 goroutine
调用通道。由于您的主线程在通道上循环，它总是从通道调用值，并且当 goroutine
完成并且通道停止发送值时，您的主线程无法从通道中获取更多值，因此条件变为死锁。为了避免这种使用sync.WaitGroup来同步异步过程。
这是代码：
package main

import (
    "fmt"
    "time"
    "sync"
)

func producer(ch chan int, d time.Duration, num int, wg *sync.WaitGroup) {
    for i:=0; i
https://play.golang.org/p/euMTGTIs83g
希望能帮助到你。
由于我的解决方案看起来与已经回答的有点相似，我在修改之前将其更改为我的原始答案以适应 OP 问题。
这是代码：
package main

import (
    "fmt"
    "time"
    "sync"
)

// producer produce values tobe sent to consumer
func producer(ch chan int, d time.Duration, num int, wg *sync.WaitGroup) {
    defer wg.Done();
    for i:=0; i
使用consumergoroutine 处理fan-in来自多个 goroutine 的所有输入，并从 goroutine
中读取所有值consumer。
希望能帮助到你。
今天关于《解决 goroutines 死锁》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！