Golang 协程间的信道

package main
 
import (
    "fmt"
    "time"
)
 
func worker(id int, c chan int) {
    for {
        // 从信道接收数据，如果信道没有数据可接收，当前协程会被阻塞
        msg := <-c
        fmt.Printf("Worker %d received message: %d\n", id, msg)
        time.Sleep(1 * time.Second) // 模拟工作时间
    }
}
 
func main() {
    // 创建一个信道，协程之间通过这个信道通信
    channel := make(chan int)
 
    // 创建并启动两个协程
    go worker(1, channel)
    go worker(2, channel)
 
    // 主协程负责向信道发送数据，以此来唤醒其他协程
    for i := 0; i < 5; i++ {
        channel <- i // 发送消息
        fmt.Printf("Main sent message: %d\n", i)
        time.Sleep(1 * time.Second) // 模拟等待时间
    }
 
    // 关闭信道，防止发生死锁
    close(channel)
}

这段代码创建了一个信道并启动了两个工作协程。主协程循环发送消息到信道，并打印出消息。每个工作协程从信道接收消息，处理任务，并打印出接收到的消息。最后，主协程关闭信道，确保不再有新的消息发送到信道中，并防止工作协程阻塞。