golang并发编程的实现
更新时间：2020-01-12 19:00:24 作者：佚名 
我要评论(0)
go
main函数的执行本身就是一个协程，当使用go关键字的时候，就会创建一个新的协程
channel
channel 管道，用于在多个协程之间传递信号
无缓存管道
当对无
main函数的执行本身就是一个协程，当使用go关键字的时候，就会创建一个新的协程
channel
channel 管道，用于在多个协程之间传递信号
无缓存管道
当对无
go
main函数的执行本身就是一个协程，当使用go关键字的时候，就会创建一个新的协程
channel
channel 管道，用于在多个协程之间传递信号
无缓存管道
当对无缓冲通道写的时候，会一直阻塞等到某个协程对这个缓冲通道读
阻塞场景：
- 通道中无数据，但执行读通道。
- 通道中无数据，向通道写数据，但无协程读取。
综上，无缓存通道的读写必须同时存在，且读写分别在两个不同的协程
func main(){
ch := make(chan int)
go func(ch chan int){
ch <-222
}(ch)
println(<-ch)
}
有缓冲管道
有缓存时可以向通道中写入数据后直接返回，缓存中有数据时可以从通道中读到数据直接返回，这时有缓存通道是不会阻塞的
阻塞场景：
- 通道的缓存无数据，但执行读通道。
- 通道的缓存已经占满，向通道写数据，但无协程读。
综上，有缓冲通道的读写必须在两个不同协程
func main() {
ch := make(chan int, 1) //长度为1的缓冲管道也是有缓冲管道
ch <- 333
go func(ch chan int) {
println(<-ch)
}(ch)
ch <- 333
}
sync.Mutex 和 sync.RwMutex
sync.Mutex 并发锁，一次只可以加载一个并发锁
sync.RwMutex 读写锁，一次可以加载多个读锁和一个写锁。当写锁存在时候，不能再加载读锁和写锁
sync.WaitGroup
阻塞等待所有任务完成之后再继续执行
WaitGroup在不方法中传递，需要传指针
func main() {
var wg sync.WaitGroup
ch := make(chan int, 1000)
for i := 0; i < 1000; i++ {
wg.Add(1)
go doSomething(i, &wg, ch)
}
wg.Wait()
fmt.Println("all done")
for i := 0; i < 1000; i++ {
dd := <-ch
fmt.Println("from ch:"+strconv.Itoa(dd))
}
}
func doSomething(index int, wg *sync.WaitGroup, ch chan int) {
defer wg.Done()
fmt.Println("start done:" + strconv.Itoa(index))
//time.Sleep(20 * time.Millisecond)
ch <- index
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
您可能感兴趣的文章:
- golang通过context控制并发的应用场景实现
- golang并发ping主机的方法
- gorm golang 并发连接数据库报错的解决方法
- golang 并发安全Map以及分段锁的实现方法
- Golang实现对map的并发读写的方法示例
- golang高并发的深入理解
- golang基础之Gocurrency并发
- golang中sync.Map并发创建、读取问题实战记录
- 详解Golang 中的并发限制与超时控制
- golang实现并发数控制的方法
- 如何利用Golang写出高并发代码详解
- Golang极简入门教程（三）：并发支持
您可能感兴趣的文章:
相关文章
go main函数的执行本身就是一个协程，当使用go关键字的时候，就会创建一个新的协程 channel channel 管道，用于在多个协程之间传递信号 无缓存管道 当对无2020-01-12- 本项目利用python以及opencv实现信用卡的数字识别 前期准备 导入工具包 定义功能函数 模板图像处理 读取模板图像 cv2.imread(img) 灰度化处理 cv22020-01-12
- 毕业之后就在一直合肥小公司工作，没有老司机、没有技术氛围，在技术的道路上我只能独自摸索。老板也只会画饼充饥，前途一片迷茫看不到任何希望。于是乎，我果断辞2020-01-12
- 应用 最近给自己的react项目添加redux的时候，用到了redux中的compose函数，使用compose来增强store，下面是我在项目中的一个应用: import {createStore,apply2020-01-12
-
Java使用DateTimeFormatter实现格式化时间
用扫描器获取输入的时间(年月日时分),这个时间的格式是常用的格式,然后格式化这个时间,把格式化的时间输出到控制台,可以在控制台重复输入时间.格式化的时间参考企业2020-01-12 - Ranorex测试报告如何发送到邮箱在网上看了下，其实可以通过在Ranorex上或者VS调用编写发送邮箱代码就可以执行发送了，RX主要涉及到的开发语言是C++或者.NET。但是我2020-01-12
- 这篇文章主要介绍了通过实例解析JMM和Volatile底层原理,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 JMM和2020-01-11
- 3*3卷积核与2*5卷积核对神经元大小的设置 #这里kerner_size = 2*5 class CONV_NET(torch.nn.Module): #CONV_NET类继承nn.Module类 def __init__(self): super(2020-01-11
-
python如何获取apk的packagename和activity
这篇文章主要介绍了python如何获取apk的packagename和activity,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-01-11 - 在pytorch中一般只对叶节点进行梯度计算，也就是下图中的d,e节点，而对非叶节点，也即是c,b节点则没有显式地去保留其中间计算过程中的梯度（因为一般来说只有叶节点2020-01-11
最新评论