在缓冲通道上使用范围时程序出现死锁

在Golang实战开发的过程中，我们经常会遇到一些这样那样的问题，然后要卡好半天，等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《在缓冲通道上使用范围时程序出现死锁》，聊聊，希望可以帮助到正在努力赚钱的你。

我正在学习 go，并且正在使用 goroutines 和通道。我正在编写一个非常人为且天真的工作池，使用两个缓冲通道，一个用于输入，一个用于输出。

现在，我在向输入通道添加作业后关闭输入通道，然后最终读取输出通道以从中读取结果，但是当我使用 for val := range ch 作为输出程序时，会发生死锁。这是示例代码

package main

import (
    "fmt"
    "time"
)

func main() {
    st := time.now()

    jobs := make(chan int, 100)
    res := make(chan int, 100)

    // putting items to the jobs channel
    for i := 0; i < 9; i++ {
        jobs <- i
    }
    close(jobs)

    go workerpool(jobs, res, 1)


    // this causes the program to panic with deadlock
    for v := range res {
        fmt.println(v)
    }

// this works just fine and program does not panics
    //for i := 0; i < 9; i++ {
    //  fmt.println(<-res)
    //}

    ed := time.now()
    fmt.println(ed.sub(st))
}

func workerpool(ip <-chan int, op chan<- int, id int) {
    for v := range ip {
        fmt.println("worker", id, "working on ", v)
        op <- 1
    }
}

这是我看到的输出

Worker 1 working on  0
Worker 1 working on  1
Worker 1 working on  2
Worker 1 working on  3
Worker 1 working on  4
Worker 1 working on  5
Worker 1 working on  6
Worker 1 working on  7
Worker 1 working on  8
1
1
1
1
1
1
1
1
1
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:
main.main()

据我所知，当我使用传统的 for loop 时，我正在获取最初放入 jobs 通道的确切数量的值 (9)。但是 for range 不是应该自动处理这个问题吗？当没有更多数据可以从通道读取时，通道将发送 false 值并且循环将终止？

解决方案

这个问题的解决方案非常明显，我所要做的就是 close 工作器中的输出通道，并且 range 由于明显的原因开始正常工作。

func workerPool(ip <-chan int, op chan<- int, id int) {
    for v := range ip {
        fmt.Println("Worker", id, "working on ", v)
        op <- fib(v)
    }
    close(op) // change made 
}

好了，本文到此结束，带大家了解了《在缓冲通道上使用范围时程序出现死锁》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！