Go程序不死锁也从不returns

Question

所附要点是一个在生产者/多消费者模型中使用通道的简单程序。出于某种原因，

go run channels.go 打印所有结果但不打印 return（并且不会死锁，或者至少 go 不会让我恐慌发生死锁。）

type walkietalkie struct {
    in chan int
    out chan int
    quit chan bool
}

var items []int = []int{
    0, 1, 2, 3, 4, 5,
}

func work1(q walkietalkie) {
    for {
        select {
        case a, more := <- q.in:
            if more {
                q.out <- a * 2
            }
        default:
            break
        }
    }
}

func work2(q walkietalkie) {
    for  {
        select {
        case a, more := <- q.in:
            if more {
                q.out <- a * -1
            }
        default:
            break
        }
    }
}

func work3(q walkietalkie) {
    for  {
        select {
        case a, more := <- q.in:
            if more {
                q.out <- a * 7
            }
            default:
                break
        }
    }
}

func main() {
    results := make(chan int, 18)
    defer close(results)

    w := []walkietalkie{
        walkietalkie{ in: make(chan int, 6), out: results, quit: make(chan bool, 1) },
        walkietalkie{ in: make(chan int, 6), out: results, quit: make(chan bool, 1) },
        walkietalkie{ in: make(chan int, 6), out: results, quit: make(chan bool, 1) },
    }

    go work1(w[0])
    go work2(w[1])
    go work3(w[2])

    // Iterate over work items
    l := len(items)
    for i, e := range items {
        // Send the work item to each worker
        for _, f := range w {
            f.in <- e // send the work item
            if i == l - 1 { // This is the last input, close the channel
                close(f.in)
            }
        }
    }

    // Read all the results from the workers
    for {
        select {
        case r, more := <-results:
            if more {
                fmt.Println(r)
            } else {
                continue
            }
        default:
            break
        }
    }

}

Answer 1

你有一些问题。

对于 1，从具有多个 return 值的通道读取，例如

case a, more := <-q.in

将在关闭的频道上进行，更多设置为 false。在你的情况下，default 永远不会被击中。

但是那些在 goroutines 中并且不会阻止程序退出。问题是你的主要 goroutine 正在做同样的事情。此外，事实证明，break 会跳出选择和 for 循环。所以如果你想打破 for 循环，那么你需要使用标签和 break LABEL.

作为替代方案，您也可以 return 而不是中断主 goroutine。

Go程序不死锁也从不returns

Go program does not deadlock but also never returns

go

channels