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

package main 本文来自zvvq

import "fmt"

func main() {

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

ch := make(chan int) 内容来自zvvq，别采集哟

// 写入数据 zvvq.cn

ch <- 42 本文来自zvvq

// 读取数据

内容来自zvvq

v := <-ch 内容来自samhan666

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

}

zvvq好，好zvvq

package main

import ( zvvq

"fmt"

内容来自samhan

"sync"

内容来自samhan666

"time" zvvq.cn

) zvvq好，好zvvq

func main() { 本文来自zvvq

// 创建一个消息队列

var (

内容来自samhan

queue = []int{}

copyright zvvq

mu    sync.Mutex 内容来自zvvq

cond  sync.Cond

) 内容来自samhan666

// 启动一个生产者 goroutine 内容来自zvvq

go func() {

for { copyright zvvq

mu.Lock() 内容来自samhan666

queue = append(queue, 42)

cond.Signal() copyright zvvq

mu.Unlock()

time.Sleep(time.Second)

本文来自zvvq

}

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

// 启动一个消费者 goroutine

本文来自zvvq

go func() { zvvq.cn

for {

zvvq好，好zvvq

mu.Lock() 内容来自zvvq，别采集哟

for len(queue) == 0 { 内容来自samhan666

cond.Wait() zvvq好，好zvvq

}

v := queue[0] 内容来自samhan

queue = queue[1:]

zvvq

mu.Unlock() 内容来自samhan

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

} copyright zvvq

}() 内容来自zvvq

// 等待 goroutine 退出

zvvq.cn

time.Sleep(time.Second 5)

} zvvq

package main 内容来自samhan666

import (

"fmt" 内容来自zvvq

"sync"

) 本文来自zvvq

func main() {

// 定义任务 zvvq好，好zvvq

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

// 创建管道

ch := make(chan int)

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

var wg sync.WaitGroup zvvq

for i := 0; i < 4; i++ { 内容来自zvvq

wg.Add(1)

zvvq好，好zvvq

go func(ch chan int) {

zvvq好，好zvvq

for task := range ch { zvvq

fmt.Println(task)

本文来自zvvq

} 本文来自zvvq

wg.Done()

本文来自zvvq

}(ch)

} copyright zvvq

// 将任务发送到管道 本文来自zvvq

for _, task := range tasks { 内容来自zvvq

ch <- task copyright zvvq

} 本文来自zvvq

// 关闭管道 内容来自samhan666

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

// 等待 goroutine 池完成

wg.Wait() 内容来自samhan666

}