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

package main

import "fmt" 内容来自samhan

func main() {

// 创建一个管道 内容来自samhan666

ch := make(chan int) zvvq好，好zvvq

// 写入数据

copyright zvvq

ch <- 42 内容来自samhan

// 读取数据 zvvq

v := <-ch zvvq好，好zvvq

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

}

zvvq

package main

import (

"fmt"

内容来自zvvq

"sync" zvvq.cn

"time"

本文来自zvvq

)

func main() {

copyright zvvq

// 创建一个消息队列 zvvq.cn

var (

内容来自zvvq，别采集哟

queue = []int{}

mu    sync.Mutex

cond  sync.Cond zvvq.cn

) 内容来自samhan666

// 启动一个生产者 goroutine zvvq.cn

go func() { 内容来自samhan

for { 内容来自zvvq，别采集哟

mu.Lock()

zvvq.cn

queue = append(queue, 42)

本文来自zvvq

cond.Signal() zvvq.cn

mu.Unlock() zvvq.cn

time.Sleep(time.Second)

内容来自zvvq

} copyright zvvq

}() 本文来自zvvq

// 启动一个消费者 goroutine

内容来自samhan

go func() {

for { 内容来自zvvq

mu.Lock()

内容来自zvvq

for len(queue) == 0 {

cond.Wait() 本文来自zvvq

} zvvq好，好zvvq

v := queue[0]

内容来自zvvq，别采集哟

queue = queue[1:]

zvvq.cn

mu.Unlock()

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

} 内容来自samhan

}()

// 等待 goroutine 退出

内容来自zvvq

time.Sleep(time.Second 5) 内容来自zvvq

} 内容来自samhan666

package main

zvvq.cn

import ( zvvq.cn

"fmt"

"sync" 内容来自zvvq

) zvvq好，好zvvq

func main() {

// 定义任务 zvvq好，好zvvq

tasks := []int{1, 2, 3, 4, 5}

内容来自samhan

// 创建管道 zvvq

ch := make(chan int) zvvq好，好zvvq

// 启动 goroutine 池来处理任务 zvvq

var wg sync.WaitGroup

zvvq.cn

for i := 0; i < 4; i++ {

内容来自zvvq

wg.Add(1)

zvvq.cn

go func(ch chan int) { 本文来自zvvq

for task := range ch { 内容来自samhan666

fmt.Println(task) copyright zvvq

} zvvq.cn

wg.Done() zvvq

}(ch) 内容来自zvvq

} 内容来自zvvq，别采集哟

// 将任务发送到管道 内容来自samhan

for _, task := range tasks { zvvq.cn

ch <- task 内容来自samhan

} copyright zvvq

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

close(ch)

// 等待 goroutine 池完成 copyright zvvq

wg.Wait() copyright zvvq

}

内容来自samhan666