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

package main 内容来自zvvq，别采集哟

import "fmt" zvvq好，好zvvq

func main() {

zvvq.cn

// 创建一个管道 copyright zvvq

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

// 写入数据 内容来自samhan

ch <- 42

// 读取数据 zvvq.cn

v := <-ch

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

} copyright zvvq

package main

copyright zvvq

import ( zvvq好，好zvvq

"fmt"

"sync"

"time" 内容来自samhan

)

func main() { zvvq.cn

// 创建一个消息队列 zvvq好，好zvvq

var ( zvvq好，好zvvq

queue = []int{}

内容来自samhan

mu    sync.Mutex 内容来自samhan666

cond  sync.Cond copyright zvvq

)

copyright zvvq

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

go func() { copyright zvvq

for {

mu.Lock() 本文来自zvvq

queue = append(queue, 42)

内容来自zvvq，别采集哟

cond.Signal()

mu.Unlock() zvvq

time.Sleep(time.Second)

zvvq.cn

}

copyright zvvq

}() 内容来自samhan

// 启动一个消费者 goroutine 内容来自zvvq

go func() { zvvq好，好zvvq

for { 内容来自samhan

mu.Lock() zvvq

for len(queue) == 0 { copyright zvvq

cond.Wait()

}

内容来自zvvq，别采集哟

v := queue[0]

queue = queue[1:]

mu.Unlock() 内容来自samhan666

fmt.Println(v) // 输出 42 内容来自zvvq，别采集哟

} 内容来自zvvq

}()

内容来自samhan666

// 等待 goroutine 退出

time.Sleep(time.Second 5) zvvq

} zvvq.cn

package main copyright zvvq

import (

zvvq好，好zvvq

"fmt"

"sync" zvvq好，好zvvq

)

内容来自zvvq，别采集哟

func main() {

zvvq

// 定义任务

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

// 创建管道 zvvq.cn

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

// 启动 goroutine 池来处理任务 内容来自zvvq

var wg sync.WaitGroup copyright zvvq

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

wg.Add(1) zvvq.cn

go func(ch chan int) { zvvq好，好zvvq

for task := range ch {

zvvq

fmt.Println(task)

copyright zvvq

} 内容来自zvvq，别采集哟

wg.Done() zvvq

}(ch) copyright zvvq

}

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

for _, task := range tasks {

ch <- task zvvq

}

// 关闭管道

close(ch) zvvq好，好zvvq

// 等待 goroutine 池完成 copyright zvvq

wg.Wait()

内容来自zvvq，别采集哟

}