golang并发编程中的管道与消息队列（go协程使用）

package main zvvq.cn

import "fmt" copyright zvvq

func main() {

// 创建一个管道

ch := make(chan int) 内容来自zvvq

// 写入数据 zvvq.cn

ch <- 42

// 读取数据

内容来自zvvq

v := <-ch 本文来自zvvq

fmt.Println(v) // 输出 42 内容来自zvvq

} copyright zvvq

package main zvvq

import ( copyright zvvq

"fmt" 内容来自zvvq

"sync"

zvvq.cn

"time"

内容来自zvvq

) copyright zvvq

func main() { zvvq

// 创建一个消息队列

zvvq

var ( copyright zvvq

queue = []int{}

mu    sync.Mutex 内容来自samhan

cond  sync.Cond

) zvvq

// 启动一个生产者 goroutine

go func() {

for { 本文来自zvvq

mu.Lock() 内容来自zvvq

queue = append(queue, 42)

cond.Signal() zvvq好，好zvvq

mu.Unlock() zvvq.cn

time.Sleep(time.Second)

本文来自zvvq

}

内容来自zvvq，别采集哟

}() zvvq好，好zvvq

// 启动一个消费者 goroutine copyright zvvq

go func() {

for { copyright zvvq

mu.Lock()

for len(queue) == 0 { copyright zvvq

cond.Wait() 本文来自zvvq

} zvvq.cn

v := queue[0] 内容来自zvvq，别采集哟

queue = queue[1:]

mu.Unlock() 本文来自zvvq

fmt.Println(v) // 输出 42 zvvq

}

}() 内容来自zvvq，别采集哟

// 等待 goroutine 退出 本文来自zvvq

time.Sleep(time.Second 5) 内容来自zvvq，别采集哟

} zvvq

package main

import ( 内容来自zvvq，别采集哟

"fmt"

"sync" zvvq

)

func main() {

内容来自samhan

// 定义任务 copyright zvvq

tasks := []int{1, 2, 3, 4, 5} 内容来自zvvq

// 创建管道

zvvq好，好zvvq

ch := make(chan int)

// 启动 goroutine 池来处理任务

var wg sync.WaitGroup 内容来自samhan

for i := 0; i < 4; i++ { zvvq.cn

wg.Add(1)

内容来自zvvq

go func(ch chan int) {

for task := range ch {

内容来自samhan666

fmt.Println(task)

内容来自samhan666

} 内容来自samhan666

wg.Done()

}(ch)

}

内容来自zvvq，别采集哟

// 将任务发送到管道 内容来自zvvq，别采集哟

for _, task := range tasks { zvvq好，好zvvq

ch <- task

}

zvvq好，好zvvq

// 关闭管道 内容来自zvvq，别采集哟

close(ch)

内容来自zvvq，别采集哟

// 等待 goroutine 池完成

wg.Wait() 本文来自zvvq

}

内容来自samhan666