Go语言中的通道chan使用指南

ch := make(chan int) // 创建一个用于传递 int 类型数据的通道

ch <- 42 // 向通道中发送数据

value := <-ch // 从通道中接收数据

close(ch) // 关闭通道

for value := range ch {
    fmt.Println(value)
}

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    for i := 0; i < 3; i++ {
        go func(id int) {
            for msg := range ch {
                fmt.Printf("Goroutine %d received: %d\n", id, msg)
            }
        }(i)
    }

    for i := 0; i < 10; i++ {
        ch <- i
        time.Sleep(100 * time.Millisecond)
    }

    close(ch)
    time.Sleep(time.Second)
}

select {
case msg1 := <-ch1:
    fmt.Println("Received from ch1:", msg1)
case msg2 := <-ch2:
    fmt.Println("Received from ch2:", msg2)
}

select {
case msg := <-ch:
    fmt.Println("Received:", msg)
case <-time.After(5 * time.Second):
    fmt.Println("Timeout")
}

package main

import (
    "fmt"
    "time"
)

func producer(ch chan<- int) {
    for i := 0; i < 5; i++ {
        ch <- i
        time.Sleep(time.Second)
    }
    close(ch)
}

func consumer(ch <-chan int) {
    for msg := range ch {
        fmt.Println("Received:", msg)
    }
}

func main() {
    ch := make(chan int)
    go producer(ch)
    consumer(ch)
}

package main

import (
    "fmt"
    "time"
)

func worker(id int, tasks <-chan int) {
    for task := range tasks {
        fmt.Printf("Worker %d processing task %d\n", id, task)
        time.Sleep(time.Second)
    }
}

func main() {
    tasks := make(chan int, 10)

    for i := 1; i <= 3; i++ {
        go worker(i, tasks)
    }

    for i := 1; i <= 10; i++ {
        tasks <- i
    }
    close(tasks)

    time.Sleep(5 * time.Second)
}