以下程序从不打印“Full”。取消注释fmt.Println(len(choke))时,当频道已满时,程序将输出“Full”。

package main

import (
    "fmt"
)

func main() {
    choke := make(chan string, 150000)

    go func() {
        for i := 0; i < 10000000; i++ {
            choke <- string(i)
            fmt.Println("i=", i)
        }
    }()

    for {
        //fmt.Println(len(choke))
        if len(choke) >= 150000 {
            fmt.Println("Full")
        }
    }
}

@ tim-heckman在OP中解释了此行为的原因。

如何在不使用热循环的情况下检测通道已满?

最佳答案

在写端使用select语句。如果有可用缓冲区或接收器正在等待,它将写入通道;如果频道已满,它将进入default情况。

func main() {
    choke := make(chan string, 150000)
    var i int
    for {
        select {
        case choke <- string(i):
            i++
        default:
            fmt.Println("Full")
            return
        }
    }
}

关于go - 在“for {len(c)}”中检查 channel 长度变得无响应,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/48939522/

10-08 20:44