func randomChain() chan interface{} { nc := make(chan interface{},32) go func() { defer close(nc) for { newData := &Data{ Value: make(map[string]interface{}) } newData.Value["car"] = RandomCarNum() nc <- newData } }() return nc } 启动两个协程获取写入chan

可以这样启动两个协程获取写入chan：

c1 := randomChain()
c2 := randomChain()

for i := 0; i < 10; i++ {
    select {
    case data1 := <-c1:
        fmt.Println("c1:", data1)
    case data2 := <-c2:
        fmt.Println("c2:", data2)
    }
}

这样就可以同时从两个 `randomChain` 协程中获取数据，每次从其中一个协程中获取到数据时，就会打印出该协程的名称和获取到的数据。由于是随机获取，所以打印的顺序可能不一致。

相关问题

func randomChain() chan interface{} { // 1 避免丢失数据 data := Data{0} nc := make(chan interface{}) count := int64(0) go func() { ticker := time.NewTicker(1 * time.Second) for { select { case <-ticker.C: fmt.Println(count) count = 0 default: nc <- &data count++ } } }() return nc } 当chan堵塞是打印提示

可以在default分支中加入一个超时机制，如果超过一定时间nc仍然没有被读取，则可以认为nc发生了堵塞情况，此时打印提示信息。例如，可以在default分支中再嵌套一个select语句，监听nc是否被读取，如果超过一定时间nc仍未被读取，则打印提示信息。代码如下：

go func() {
    ticker := time.NewTicker(1 * time.Second)
    for {
        select {
        case <-ticker.C:
            fmt.Println(count)
            count = 0
        default:
            select {
            case nc <- &data:
                count++
            case <-time.After(100 * time.Millisecond):
                fmt.Println("chan is blocked")
            }
        }
    }
}()

这里使用了time.After函数来创建一个超时的channel，如果在100毫秒内nc仍未被读取，则会从After函数返回的channel中读取到数据，从而触发打印提示信息。需要注意的是，这里的超时时间100毫秒应该根据实际情况进行调整。

func randomChain() chan interface{} { // 1 避免丢失数据 data := Data{0} nc := make(chan interface{}) count := int64(0) go func() { ticker := time.NewTicker(1 * time.Second) for { select { case <-ticker.C: fmt.Println(count) count = 0 default: nc <- &data count++ } } }() return nc } 如何检测是否有chan堵塞情况发生

可以通过在select语句中使用default分支来检测是否有chan堵塞情况发生。在上述代码中，如果在1秒钟内没有从nc中读取数据，则会执行default分支，向nc中写入数据，如果一直执行default分支，说明nc一直在阻塞，即发生了chan堵塞情况。因此我们可以在default分支中记录一个计数器，如果计数器的值达到一定阈值，就可以认为发生了chan堵塞情况。可以通过观察计数器的值来判断chan是否正常工作。