为什么 Go 会因“致命错误：所有 goroutine 都处于睡眠状态”而死锁

Question

这是我的代码的相关摘录：

func main() {
    quit := make(chan int)

    readyQueue := make(chan Proc)
    runQueue := make(chan Proc)
    waitQueue := make(chan Proc)

    procList := getInitialProcList()
    fmt.Println(procList)

    for _, proc := range(procList) {
        switch {
            case proc.Status == READY:
                readyQueue <- proc
                tick(quit, readyQueue, runQueue, waitQueue)
            case proc.Status == RUN:
                runQueue <- proc
                tick(quit, readyQueue, runQueue, waitQueue)
            case proc.Status == WAIT:
                waitQueue <- proc
                tick(quit, readyQueue, runQueue, waitQueue)
        }
    }

    <-quit // blocks to keep main thread alive
}

func tick(quit chan int, readyQueue chan Proc, runQueue chan Proc, waitQueue chan Proc) {
    select {
    case p := <-readyQueue:
        fmt.Println(p)
    default:
        fmt.Println("[tick] nothing in ready queue")
    }

    select {
    case p := <-waitQueue:
        fmt.Println(p)
    default:
        fmt.Println("[tick] nothing in wait queue")
    }

    select {
    case p := <-runQueue:
        fmt.Println(p)
    default:
        fmt.Println("[tick] nothing in run queue")
    }

    quit <- 0
}

我不明白为什么我在上面代码中的readyQueue <- proc 行上收到错误fatal error: all goroutines are asleep - deadlock!。

Answer 1

就代码显示而言，您永远不会为您创建的任何通道启动并发阅读器。因为它们是无缓冲的，所以对它们的任何写入都会阻塞，直到有人在某处从另一端读取。您的代码中不是这种情况。

如果tick 应该是消费者，你应该在进入循环之前启动它。 然后它本身应该有一个循环，因此它会不断轮询通道以获取新值。

go tick(quit, readyQueue, runQueue, waitQueue)

for _, proc := range(procList) {
    ....
}

另一个直接的解决方案是创建缓冲区为 1 的所有通道。

quit := make(chan int, 1)

readyQueue := make(chan Proc, 1)
runQueue := make(chan Proc, 1)
waitQueue := make(chan Proc, 1)

虽然这将解决您的直接问题，但您的设计仍然存在一些其他潜在问题。我们需要确切地知道您想要完成什么，以便给出更全面的答案。