Golang에서 Select Channels Go 동시 프로그래밍의 효율성을 향상시키는 방법

func main() {
    tasks := make(chan int)
    results := make(chan int)
    
    // 启动消费者
    go consumer(results)
    
    // 启动生产者
    go producer(tasks)
    
    // 等待所有任务都完成
    for i := 0; i < 10; i++ {
        <-results
    }
}

func producer(tasks chan<- int) {
    // 向tasks channel发送任务
    for i := 0; i < 10; i++ {
        tasks <- i
    }
    close(tasks)
}

func consumer(results chan<- int) {
    for task := range tasks {
        // 处理任务
        // ...
        
        // 将结果发送到results channel
        results <- result
    }
    close(results)
}

func main() {
    a := make(chan int)
    b := make(chan int)
    c := make(chan int)
    
    // 启动goroutine发送数据到channel
    go func() {
        for i := 0; i < 1000; i++ {
            a <- i
            time.Sleep(time.Millisecond)
        }
        close(a)
    }()
    
    // 使用Select选择数据
    for i := 0; i < 1000; i++ {
        select {
        case x := <-a:
            // 处理a的数据
            fmt.Println("a:", x)
        case x := <-b:
            // 处理b的数据
            fmt.Println("b:", x)
        case x := <-c:
            // 处理c的数据
            fmt.Println("c:", x)
        default:
            // 如果没有数据可选择，则执行其他操作
            fmt.Println("no data")
        }
    }
}

var mutex sync.Mutex

func main() {
    c := make(chan int)
    
    // 启动消费者
    go consumer(c)
    
    // 启动生产者
    go producer(c)
    
    // 等待任务完成
    time.Sleep(time.Second)
}

func producer(c chan<- int) {
    for i := 0; i < 100; i++ {
        mutex.Lock()
        c <- i
        mutex.Unlock()
    }
    close(c)
}

func consumer(c <-chan int) {
    for task := range c {
        mutex.Lock()
        // 处理任务
        mutex.Unlock()
    }
}