zvvq技术分享网

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

作者:zvvq博客网
导读管道和消息队列是 go 中用于 goroutine 通信的原语。管道是无缓冲通道,立即传递数据;消息队列是缓冲通道,允许存储多个消息。实战案例中,管道可用于并行处理任务,如将一组任务

管道和消息队列是 go 中用于 goroutine 通信的原语。管道是无缓冲通道,立即传递数据;消息队列是缓冲通道,允许存储多个消息。实战案例中,管道可用于并行处理任务,如将一组任务发送到管道并使用 goroutine 池并行处理。

内容来自zvvq,别采集哟

内容来自zvvq,别采集哟

Go 中的管道与消息队列

zvvq

在 Go 中,管道和消息队列是用于 goroutine 之间通信的两个基本原语。 zvvq.cn

管道 copyright zvvq

go语言免费”;

内容来自samhan666

管道是无缓冲的通信通道,数据会立即从写入端传递到读取端。管道通常用于在 goroutine 之间传递小块数据。

本文来自zvvq

创建管道: 本文来自zvvq

1

内容来自samhan666

2

zvvq.cn

3

zvvq.cn

4 本文来自zvvq

5 zvvq

6 内容来自samhan

7

zvvq好,好zvvq

8 zvvq

9

内容来自samhan666

10 copyright zvvq

11

内容来自zvvq,别采集哟

12 本文来自zvvq

13

copyright zvvq

14

本文来自zvvq

15 zvvq.cn

package main 本文来自zvvq

import "fmt"

内容来自zvvq,别采集哟

func main() {

zvvq好,好zvvq

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

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

// 写入数据 zvvq.cn

ch <- 42 本文来自zvvq

// 读取数据

内容来自zvvq

v := <-ch 内容来自samhan666

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

}

zvvq好,好zvvq

消息队列 zvvq

消息队列是一种缓冲的通信通道,允许在写入端和读取端之间存储多个消息。这使得 goroutine 可以按自己的节奏发送和接收消息,而不必担心丢失或阻塞。

zvvq好,好zvvq

使用内置的 sync.Mutex 和 sync.Cond 创建一个简单的消息队列:

内容来自samhan666

1

copyright zvvq

2

zvvq好,好zvvq

3 内容来自samhan666

4

zvvq好,好zvvq

5 内容来自samhan666

6

内容来自samhan666

7

copyright zvvq

8 zvvq

9

zvvq

10

zvvq.cn

11 内容来自zvvq

12

zvvq好,好zvvq

13 本文来自zvvq

14

内容来自zvvq

15

内容来自zvvq

16

内容来自samhan666

17 zvvq好,好zvvq

18 内容来自samhan

19

copyright zvvq

20

内容来自samhan

21

内容来自samhan666

22

本文来自zvvq

23 zvvq

24 内容来自zvvq

25 内容来自samhan

26 zvvq.cn

27

内容来自samhan666

28 zvvq.cn

29 zvvq.cn

30

内容来自zvvq,别采集哟

31 zvvq好,好zvvq

32 zvvq

33

zvvq.cn

34

内容来自zvvq,别采集哟

35

内容来自zvvq,别采集哟

36

zvvq

37

zvvq好,好zvvq

38 copyright zvvq

39

内容来自samhan666

40

内容来自zvvq

41 内容来自zvvq,别采集哟

42

内容来自zvvq,别采集哟

43 zvvq好,好zvvq

44 zvvq好,好zvvq

package main

内容来自zvvq,别采集哟

import ( zvvq

"fmt"

内容来自samhan

"sync"

内容来自samhan666

"time" zvvq.cn

) zvvq好,好zvvq

func main() { 本文来自zvvq

// 创建一个消息队列

zvvq.cn

var (

内容来自samhan

queue = []int{}

copyright zvvq

mu    sync.Mutex 内容来自zvvq

cond  sync.Cond

copyright zvvq

) 内容来自samhan666

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

go func() {

本文来自zvvq

for { copyright zvvq

mu.Lock() 内容来自samhan666

queue = append(queue, 42)

本文来自zvvq

cond.Signal() copyright zvvq

mu.Unlock()

内容来自samhan

time.Sleep(time.Second)

本文来自zvvq

}

内容来自samhan

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

// 启动一个消费者 goroutine

本文来自zvvq

go func() { zvvq.cn

for {

zvvq好,好zvvq

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

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

cond.Wait() zvvq好,好zvvq

}

zvvq.cn

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)

copyright zvvq

} zvvq

实战案例:并行处理任务 zvvq

管道或消息队列可以用于并行处理任务。以下是一个示例,说明如何使用管道并行处理一组任务: 内容来自zvvq,别采集哟

1

zvvq

2

zvvq

3

zvvq好,好zvvq

4

内容来自zvvq,别采集哟

5

copyright zvvq

6 内容来自samhan666

7

内容来自zvvq

8 内容来自zvvq

9 zvvq

10 zvvq.cn

11 内容来自samhan666

12 内容来自samhan

13 本文来自zvvq

14 内容来自zvvq

15

zvvq好,好zvvq

16

内容来自zvvq

17

本文来自zvvq

18

内容来自zvvq,别采集哟

19 zvvq好,好zvvq

20 zvvq.cn

21 copyright zvvq

22

copyright zvvq

23

zvvq

24 内容来自zvvq,别采集哟

25

zvvq

26 内容来自zvvq,别采集哟

27

zvvq

28 zvvq.cn

29 zvvq

30 内容来自zvvq,别采集哟

31 本文来自zvvq

32

内容来自zvvq

33

本文来自zvvq

34

内容来自zvvq

35

zvvq.cn

36 内容来自zvvq

37 zvvq好,好zvvq

package main 内容来自samhan666

import (

copyright zvvq

"fmt" 内容来自zvvq

"sync"

内容来自samhan

) 本文来自zvvq

func main() {

zvvq好,好zvvq

// 定义任务 zvvq好,好zvvq

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

本文来自zvvq

// 创建管道

内容来自zvvq,别采集哟

ch := make(chan int)

内容来自zvvq

// 启动 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)

zvvq.cn

} copyright zvvq

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

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

ch <- task copyright zvvq

} 本文来自zvvq

// 关闭管道 内容来自samhan666

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

// 等待 goroutine 池完成

zvvq.cn

wg.Wait() 内容来自samhan666

}

内容来自zvvq

以上就是golang并发编程中的管道与消息队列的详细内容,更多请关注其它相关文章!

内容来自zvvq,别采集哟