脚本之家,脚本语言编程技术及教程分享平台!
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - Go语言通道之缓冲通道

Go语言通道之缓冲通道

2022-07-16 14:06奋斗的大橙子 Golang

这篇文章介绍了Go语言通道之缓冲通道,文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下

前文为大家讲解了Go语言通道之无缓冲通道

有缓冲的通道相比于无缓冲通道,多了一个缓存的功能,如下图描述的一样:

Go语言通道之缓冲通道

从图上可以明显看到和无缓冲通道的区别,无缓冲必须两个Goroutine都进入通道才能进行数据的交换,这个不用,如果数据有,直接就能拿走。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package ChannelDemo
 
import (
    "fmt"
    "math/rand"
    "sync"
    "time"
)
 
const (
    numberGoroutines = 4
    taskLoad         = 10
)
 
var bufferWg sync.WaitGroup
 
func init() {
    rand.Seed(time.Now().Unix())
}
 
func main() {
    //创建了一个10任务的缓冲通道
    tasks := make(chan string, taskLoad)
    bufferWg.Add(numberGoroutines)
 
    //创建4个Goroutine
    for gr := 1; gr <= numberGoroutines; gr++ {
        go worker(tasks, gr)
    }
 
    //向缓冲通道中放入数据
    for post := 1; post <= taskLoad; post++ {
        tasks <- fmt.Sprintf("Task : %d", post)
    }
 
    close(tasks)
 
    bufferWg.Wait()
}
 
func worker(tasks chan string, worker int) {
    defer bufferWg.Done()
 
    for {
        task, ok := <-tasks
        if !ok {
            fmt.Printf("Worker: %d : 结束工作 \n", worker)
            return
        }
 
        fmt.Printf("Worker: %d : 开始工作 %s\n", worker, task)
 
        //随机处理一下工作的时间
        sleep := rand.Int63n(100)
        time.Sleep(time.Duration(sleep) * time.Millisecond)
 
        fmt.Printf("Worker: %d : 完成工作 %s\n", worker, task)
    }
}

运行结果:

Worker: 3 : 开始工作 Task : 4
Worker: 2 : 开始工作 Task : 2
Worker: 1 : 开始工作 Task : 1
Worker: 4 : 开始工作 Task : 3
Worker: 4 : 完成工作 Task : 3
Worker: 4 : 开始工作 Task : 5
Worker: 2 : 完成工作 Task : 2
Worker: 2 : 开始工作 Task : 6
Worker: 3 : 完成工作 Task : 4
Worker: 3 : 开始工作 Task : 7
Worker: 1 : 完成工作 Task : 1
Worker: 1 : 开始工作 Task : 8
Worker: 3 : 完成工作 Task : 7
Worker: 3 : 开始工作 Task : 9
Worker: 1 : 完成工作 Task : 8
Worker: 1 : 开始工作 Task : 10
Worker: 4 : 完成工作 Task : 5
Worker: 4 : 结束工作
Worker: 3 : 完成工作 Task : 9
Worker: 3 : 结束工作
Worker: 2 : 完成工作 Task : 6
Worker: 2 : 结束工作
Worker: 1 : 完成工作 Task : 10
Worker: 1 : 结束工作 

因为哪一个worker先从通道中取值有系统自己进行调度的,所以每次运行的结果稍微不同,但是相同的是10个任务被4个协程有条不紊的完成了

注意:main中有一句代码 Close(tasks) 关闭通道的代码非常重要。当通道关闭后,goroutine 依旧可以从通道接收数据,但是不能再向通道里发送数据。

能够从已经关闭的通道接收数据这一点非常重要,因为这允许通道关闭后依旧能取出其中缓冲的全部值,而不会有数据丢失.

总结

无缓冲的通道保证同时交换数据,而有缓冲的通道不做这种保证。

到此这篇关于Go语言通道之缓冲通道的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持服务器之家。

原文链接:https://www.cnblogs.com/dcz2015/p/10384067.html

延伸 · 阅读

精彩推荐
  • Golanggo语言接口用法实例分析

    go语言接口用法实例分析

    这篇文章主要介绍了go语言接口用法,实例分析了Go语言接口的定义及使用技巧,需要的朋友可以参考下 ...

    两把刷子2132020-04-20
  • GolangGo 面试官问我如何实现面向对象?

    Go 面试官问我如何实现面向对象?

    在大家初识 Go 语言时,总会拿其他语言的基本特性来类比 Go 语言,说白了就是老知识和新知识产生关联,实现更高的学习效率。...

    脑子进煎鱼了12472021-05-21
  • Golang浅谈Go Channel 高级实践

    浅谈Go Channel 高级实践

    这篇文章主要介绍了浅谈Go Channel 高级实践,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧 ...

    sxssxs6732020-05-19
  • Golanggolang如何实现mapreduce单进程版本详解

    golang如何实现mapreduce单进程版本详解

    这篇文章主要给大家介绍了关于golang如何实现mapreduce单进程版本的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学...

    VINLLEN CHEN4822020-05-13
  • GolangGo语言操作数据库及其常规操作的示例代码

    Go语言操作数据库及其常规操作的示例代码

    这篇文章主要介绍了Go语言操作数据库及其常规操作的示例代码,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需...

    听风走了八千里7172021-05-26
  • GolangGolang 发送http请求时设置header的实现

    Golang 发送http请求时设置header的实现

    这篇文章主要介绍了Golang 发送http请求时设置header的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋...

    Archmage102413462020-06-04
  • Golang用Go+Redis实现分布式锁的示例代码

    用Go+Redis实现分布式锁的示例代码

    在分布式的业务中 , 如果有的共享资源需要安全的被访问和处理 , 那就需要分布式锁,本文主要介绍了用Go+Redis实现分布式锁的示例代码,感兴趣的可以了...

    kevinwan5782022-01-24
  • Golanggolang方法中receiver为指针与不为指针的区别详析

    golang方法中receiver为指针与不为指针的区别详析

    这篇文章主要给大家介绍了关于golang方法中receiver为指针与不为指针区别的相关资料,其实最大的区别应该是指针传递的是对像的引用,文中通过示例代码...

    pinecone3892020-05-09