Go管道堵塞的避免

为了避免Go管道的阻塞，我们可以使用 select 语句结合 default 分支。 select 语句允许同时在多个管道上进行非阻塞操作。

以下是一个示例，展示了如何使用 select 语句来避免管道阻塞：

package main

import "fmt"

func main() {
   
    ch1 := make(chan int)
    ch2 := make(chan int)

    go func() {
   
        for i := 1; i <= 5; i++ {
   
            ch1 <- i
        }
        close(ch1)
    }()

    go func() {
   
        for i := 6; i <= 10; i++ {
   
            ch2 <- i
        }
        close(ch2)
    }()

    for {
   
        select {
   
        case num, ok := <-ch1:
            if ok {
   
                fmt.Println("Received from ch1:", num)
            } else {
   
                fmt.Println("ch1 closed")
            }
        case num, ok := <-ch2:
            if ok {
   
                fmt.Println("Received from ch2:", num)
            } else {
   
                fmt.Println("ch2 closed")
            }
        default:
            fmt.Println("No data available")
            return
        }
    }
}

在上面的例子中，我们创建了两个整数类型的管道 ch1 和 ch2 。我们使用两个协程分别向这两个管道发送数据，并在发送完之后关闭管道。

在主协程中，我们使用 select 语句来同时监听两个管道的接收操作。当有数据可用时，我们从相应的管道接收数据并打印出来。如果没有数据可用， default 分支将会执行，避免阻塞。

通过使用 select 语句和 default 分支，我们可以在多个管道之间进行非阻塞的操作，避免管道的阻塞问题。