我想编写三个相互发送整数的并发 go 例程。现在，我的代码已正确编译，但在第一次执行后出现错误“所有 goroutines 都睡着了 - 死锁!”。我试图找到错误，但我无法在代码逻辑中找到任何错误。任何人都可以帮助我找到我的代码中的错误。我的代码如下。提前致谢。

package main

import "rand"

func Routine1(command12 chan int, response12 chan int, command13 chan int, response13 chan int) {
    for i := 0; i < 10; i++ {
        y := rand.Intn(10)
        if y%2 == 0 {
            command12 <- y
        }

        if y%2 != 0 {
            command13 <- y
        }
        select {
        case cmd1 := <-response12:
            print(cmd1, " 1st\n")
        case cmd2 := <-response13:
            print(cmd2, " 1st\n")
        }
    }
    close(command12)
}

func Routine2(command12 chan int, response12 chan int, command23 chan int, response23 chan int) {
    for i := 0; i < 10; i++ {
        select {
        case x, open := <-command12:
            {
                if !open {
                    return
                }
                print(x, " 2nd\n")
            }

        case x, open := <-response23:
            {
                if !open {
                    return
                }
                print(x, " 2nd\n")
            }
        }

        y := rand.Intn(10)
        if y%2 == 0 {
            response12 <- y
        }

        if y%2 != 0 {
            command23 <- y
        }

    }
}

func Routine3(command13 chan int, response13 chan int, command23 chan int, response23 chan int) {
    for i := 0; i < 10; i++ {
        select {
        case x, open := <-command13:
            {
                if !open {
                    return
                }
                print(x, " 2nd\n")
            }
        case x, open := <-command23:
            {
                if !open {
                    return
                }
                print(x, " 2nd\n")
            }
        }

        y := rand.Intn(10)
        if y%2 == 0 {
            response13 <- y
        }

        if y%2 != 0 {
            response23 <- y
        }

    }
}

func main() {
    command12 := make(chan int)
    response12 := make(chan int)
    command13 := make(chan int)
    response13 := make(chan int)
    command23 := make(chan int)
    response23 := make(chan int)

    go Routine1(command12, response12, command13, response13)
    go Routine2(command12, response12, command23, response23)
    Routine3(command13, response13, command23, response23)
}

谁能告诉我为什么如果我将 Routine2 和 Routine3 声明为 go routine，为什么输出是 [no output]。我是 GO 的新手，据我从“http://golang.org/doc/effective_go.html#concurrency”中了解到，go 用于与同一地址空间中的其他 goroutine 并行执行 goroutine。那么，问题是什么，所有例程都在运行，但输出是[无输出]。

为了使程序更清晰:实际上我很累的是在每两个例程之间创建两个 channel ，然后使用一个 channel 将 int 发送到另一个 channel 并通过另一个 channel 从该例程接收 int。例如，例程 1 和 3 之间的 channel 是命令 13 和响应 13。例程 1 使用 command13 发送 int 和 response13 从例程 3 接收 int。对于例程 3，response13 用于向例程 1 发送 int 和 command13 接收 int(命令/响应 13 表示例程 1 和例程 3 之间的 channel )。现在，由于三个例程是并发的，并且它们有特定的例程来处理接收到的消息或发送消息，为什么它们会陷入死锁？

最佳答案

go Routine1(command12, response12,command13, response13 )
go Routine2(command12, response12,command23, response23) // go routine
Routine3(command12, response12,command23, response23 )

这将在一个新的 goroutine 中启动 Routine1，主 goroutine 将继续执行下一条语句。因此，Routine1 和Routine2 会同时执行，但Routine3 会在Routine2 执行完后才开始执行。您可能会在这里错过另一个“go”语句。

然后，我尝试按照您的程序进行操作。在 Routine1 中你做

command13 <- y

这会阻塞 Routine1，直到有另一个 goroutine 准备好接收你的消息。所以你需要一个 y := <-command13在另一个 goroutine 中。

但是现在，让我们仔细看看其他两个 goroutine 的参数:

Routine2(command12, response12,command23, response23)
Routine3(command12, response12,command23, response23 )

如您所见，没有一个 goroutine 可以访问 command13(但您传递了 command12 两次)。因此，Routine1、Routine2 或 Routine3 都无法继续。死锁!

我建议您回到绘图板。首先考虑您要尝试做什么，绘制一些关于预期消息流的图表，然后尝试实现该行为。

目前很难调试你的程序，因为，

• 我不知道你想做什么。没有关于消息流或类似内容的详细描述。事实上，您的代码根本不包含任何文档。
• 您正在通过名为 response23 的 channel 到一个名为 response13 的参数等等。很容易将它们混在一起。
• 所有这些通用名称，如 command12 等，让人很难理解这个 channel 应该做什么
• gofmt 是个好主意发布之前的源代码:)

作为起点，我可以向您推荐 Go tutorial 中的“质数”示例.在此示例中，可能的素数从一个 goroutine 传递到另一个 goroutine。此外，该示例还包含一些关于消息流的漂亮图形以及一些非常好的解释。你可能会喜欢它。

关于go - 所有的 goroutines 都睡着了——死锁! - - - - 错误，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/8246065/