Go语言使用select监听多个channel的示例详解

package main

import (
    "fmt"
    "math/rand"
    "time"
)

func task(name string, delay time.Duration, ch chan<- string) {
    time.Sleep(delay)
    ch <- fmt.Sprintf("任务 %s 完成（耗时 %v）", name, delay)
}

func main() {
    rand.Seed(time.Now().UnixNano())

    task1Ch := make(chan string)
    task2Ch := make(chan string)

    // 启动两个任务
    go task("A", time.Duration(rand.Intn(2000))*time.Millisecond, task1Ch)
    go task("B", time.Duration(rand.Intn(2000))*time.Millisecond, task2Ch)

    // 使用 select 监听两个任务完成情况
    timeout := time.After(2 * time.Second) // 超时设置

    for i := 0; i < 2; i++ {
        select {
        case res := <-task1Ch:
            fmt.Println("[监听] 收到任务1结果：", res)
        case res := <-task2Ch:
            fmt.Println("[监听] 收到任务2结果：", res)
        case <-timeout:
            fmt.Println("[监听] 等待超时！")
            return
        }
    }

    fmt.Println("主程序退出。")
}

timeout := time.After(2 * time.Second)

select {
case msg := <-ch:
    fmt.Println("收到消息：", msg)
default:
    fmt.Println("没有消息，非阻塞处理")
}

func main() {
    dataCh := make(chan string)
    quitCh := make(chan bool)

    // 模拟异步数据流
    go func() {
        for i := 0; i < 5; i++ {
            dataCh <- fmt.Sprintf("数据包 #%d", i)
            time.Sleep(time.Millisecond * 500)
        }
        quitCh <- true
    }()

    for {
        select {
        case msg := <-dataCh:
            fmt.Println("接收数据：", msg)
        case <-quitCh:
            fmt.Println("任务结束，退出监听循环")
            return
        case <-time.After(1 * time.Second):
            fmt.Println("1秒无数据，超时处理...")
        }
    }
}