golang并发编程中的管道与消息队列

package main

import "fmt"

func main() {
    // 创建一个管道
    ch := make(chan int)

    // 写入数据
    ch <- 42

    // 读取数据
    v := <-ch
    fmt.Println(v) // 输出 42
}

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    // 创建一个消息队列
    var (
        queue = []int{}
        mu    sync.Mutex
        cond  sync.Cond
    )

    // 启动一个生产者 goroutine
    go func() {
        for {
            mu.Lock()
            queue = append(queue, 42)
            cond.Signal()
            mu.Unlock()
            time.Sleep(time.Second)
        }
    }()

    // 启动一个消费者 goroutine
    go func() {
        for {
            mu.Lock()
            for len(queue) == 0 {
                cond.Wait()
            }
            v := queue[0]
            queue = queue[1:]
            mu.Unlock()
            fmt.Println(v) // 输出 42
        }
    }()

    // 等待 goroutine 退出
    time.Sleep(time.Second * 5)
}

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 定义任务
    tasks := []int{1, 2, 3, 4, 5}

    // 创建管道
    ch := make(chan int)

    // 启动 goroutine 池来处理任务
    var wg sync.WaitGroup
    for i := 0; i < 4; i++ {
        wg.Add(1)
        go func(ch chan int) {
            for task := range ch {
                fmt.Println(task)
            }
            wg.Done()
        }(ch)
    }

    // 将任务发送到管道
    for _, task := range tasks {
        ch <- task
    }

    // 关闭管道
    close(ch)

    // 等待 goroutine 池完成
    wg.Wait()
}