go 协程返回值处理操作
来源:脚本之家
时间:2023-01-09 17:43:56 384浏览 收藏
IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《go 协程返回值处理操作》,聊聊GO协程、返回值,我们一起来看看吧!
我就废话不多说了,大家还是直接看代码吧~
package main import "fmt" import "sync" var ch = make(chan int) func do(lock *sync.Mutex, ct *int) { lock.Lock() *ct++ lock.Unlock() ch
输出: 10
补充:Goroutine协程之间的数据沟通的方式
一个服务器物理线程能够跑多个goroutine,成千上万个goroutine 实际上跑在物理线程上的也就几十个,但是java和c++创建成千上万个线程会使得系统反应更慢,这是为什么goroutine能很快的原因。
那么goroutine协程之间是如何进行通信的呢?有两种方式,
第一使用全局变量和锁同步:读写锁或互斥锁对全局变量进行加锁,实现多个goroute的数据共享。
第二:Channel 管道进行数据同步
1.加锁操作
互斥锁就是将公共资源进行加锁操作,以便于goroute对数据进行更改。
package main import ( "fmt" lock "sync" "time" ) type task struct { n int } //通过全局的 map 来通讯 var ( sum ) func calc(t *task) { var sum uint64 sum = 1 for i := 1; i2.channel管道通信
单纯地将函数并发执行是没有意义的。函数与函数间需要交换数据才能体现并发执行函数的意义。虽然可以使用共享内存进行数据交换,但是共享内存在不同的 goroutine 中容易发生竞态问题。为了保证数据交换的正确性,必须使用互斥量对内存进行加锁,这种做法势必造成性能问题。
Go 语言提倡使用通信的方法代替共享内存,这里通信的方法就是使用通道(channel)
channel 具有几个特性:
1.类似unix中的管道(pipe)
2.先进先出
3.线程安全,多个goroutine同时访问,不需要加锁
4.channel是有类型的,一个整数的channel 只能存放整
2.1使用通道发送数据
通道创建后,就可以使用通道进行发送和接收操作。
1) 通道发送数据的格式
通道的发送使用特殊的操作符
通道变量
通道变量:通过make创建好的通道实例。
值:可以是变量、常量、表达式或者函数返回值等。值的类型必须与ch通道的元素类型一致。
2) 通过通道发送数据的例子
使用 make 创建一个通道后,就可以使用
// 创建一个空接口通道 ch := make(chan interface{}) // 将0放入通道中 ch2.2 使用通道接收数据
1)通道接收同样使用
① 通道的收发操作在不同的两个 goroutine 间进行。
由于通道的数据在没有接收方处理时,数据发送方会持续阻塞,因此通道的接收必定在另外一个 goroutine 中进行。
② 接收将持续阻塞直到发送方发送数据。
如果接收方接收时,通道中没有发送方发送数据,接收方也会发生阻塞,直到发送方发送数据为止
③ 每次接收一个元素。
通道一次只能接收一个数据元素。
通道的数据接收一共有以下 4 种写法。
2) 阻塞接收数据
阻塞模式接收数据时,将接收变量作为
data :=
执行该语句时将会阻塞,直到接收到数据并赋值给 data 变量。
3) 非阻塞接收数据
使用非阻塞方式从通道接收数据时,语句不会发生阻塞,格式如下:
data, ok :=
data:表示接收到的数据。未接收到数据时,data 为通道类型的零值。
ok:表示是否接收到数据。
非阻塞的通道接收方法可能造成高的 CPU 占用,因此使用非常少。如果需要实现接收超时检测,可以配合 select 和计时器 channel 进行,可以参见后面的内容。
4) 接收任意数据,忽略接收的数据
阻塞接收数据后,忽略从通道返回的数据,格式如下:
执行该语句时将会发生阻塞,直到接收到数据,但接收到的数据会被忽略。这个方式实际上只是通过通道在 goroutine 间阻塞收发实现并发
2.3 发生阻塞的2种情况
1)发送方发送阻塞:在通道数据没有接收方处理时,通道的数据一开始会存放到固定的数据缓冲区内,超出缓冲区的大小将发生持续阻塞。
package main func main() { var ch chan int ch = make(chan int, 5) //定义数据缓存区设置为5个大小 //将数据保存在缓冲区内并不会发生当前线程阻塞 for i := 0; i这个程序的执行结果直接painc 因为在管道加入ch
2) 数据接收方发生阻塞:如果接收方没有接收到数据,接收方等待发送方发送数据,等待的过程也会使数据接收的协程发生阻塞。
package main import ( "fmt" "time" ) func main() { var ch chan int ch = make(chan int) //无定义数据缓存区 go func() { var a =这个程序的执行结果是延时4秒后控制台打印出通道的值1,5秒后主程序结束。上边的程序是先让接收者协程开启等待接收通道的值,而发送者是主函数延迟4秒后才将值放入通道ch,匿名函数中不得不等待发送者的值,所以造成了匿名并发函数的阻塞。 我们可以思考到,如果去掉4秒等待的时间, 这个程序就是使用channel作为协程之间同步的最简单的例子,我们发现channel同步的特性就是无数据缓存区。
同样一个程序,当你把接受者 go func() 程序放到 ch
package main import ( "fmt" "time" ) func main() { var ch chan int ch = make(chan int) //无定义数据缓存区 //time.Sleep(time.Second * 4) //主线程等待4才给管道数据 ch以上为个人经验,希望能给大家一个参考,也希望大家多多支持golang学习网。如有错误或未考虑完全的地方,望不吝赐教。
终于介绍完啦!小伙伴们,这篇关于《go 协程返回值处理操作》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!
-
358 收藏
-
267 收藏
-
486 收藏
-
302 收藏
-
335 收藏
-
225 收藏
-
485 收藏
-
233 收藏
-
322 收藏
-
181 收藏
-
316 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 507次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习