Go语言的并发和并行
2024-08-25 09:19:17
不知道你有没有注意到,这段代码如果我跑在两个goroutines里面的话:
package main import (
"fmt"
) func loop(done chan bool) {
for i := 0; i < 10; i++ {
fmt.Print(i)
}
done <- true
} func main() {
done := make(chan bool)
go loop(done)
go loop(done) <-done
<-done }
他的输出结果: 01234567890123456789
go不是会新起一个goroutine来运行loop函数吗。以前我们用线程去做类似任务的时候,系统的线程会抢占式地输出, 表现出来的是乱序地输出。而goroutine为什么是这样输出的呢?
关于并行和并发,下面这张图说明:
- 两个队列,一个Coffee机器,那是并发
- 两个队列,两个Coffee机器,那是并行
默认地, Go所有的goroutines只能在一个线程里跑 。
如果当前goroutine不发生阻塞,它是不会让出CPU给其他goroutine的, 所以上面的例子的输出会是一个一个goroutine进行的
真正的并行
为了达到真正的并行,runtime.GOMAXPROCS(2)试试看
package main import (
"fmt"
"runtime"
) func loop(done chan bool) {
for i := 0; i < 100; i++ {
fmt.Printf("%d ", i)
}
done <- true
} func main() {
runtime.GOMAXPROCS(2)
done := make(chan bool)
go loop(done)
go loop(done) <-done
<-done }
这下会看到两个goroutine会抢占式地输出数据了。我们还可以这样显式地让出CPU时间:
package main import (
"fmt"
"runtime"
) func loop(done chan bool) {
for i := 0; i < 100; i++ {
fmt.Printf("%d ", i)
runtime.Gosched() //// 显式地让出CPU时间给其他goroutine
}
done <- true
} func main() {
// runtime.GOMAXPROCS(2)
done := make(chan bool)
go loop(done)
go loop(done) <-done
<-done }
总结
我们从例子中可以看到,默认的, 所有goroutine会在一个原生线程里跑
在同一个原生线程里,如果当前goroutine不发生阻塞,它是不会让出CPU时间给其他同线程的goroutines的,这是Go运行时对goroutine的调度,我们也可以使用runtime包来手工调度。
当一个goroutine发生阻塞,Go会自动地把与该goroutine处于同一系统线程的其他goroutines转移到另一个系统线程上去,以使这些goroutines不阻塞
最新文章
- WeText项目:一个基于.NET实现的DDD、CQRS与微服务架构的演示案例
- css3 animation动画特效插件的巧用
- 转载 - Vultr VPS注册开通且一键快速安装PPTP VPN和电脑连接使用
- 自己动手搭建 Redis 环境,并建立一个 .NET HelloWorld 程序测试
- svn 结合rsync 的代码发布系统
- 循环语句for
- SQL Server 索引重建的 4 种方法
- Javascript进阶篇——(函数)笔记整理
- 【MyBatis源码分析】插件实现原理
- JAVA_SE基础——32.this关键字调用本类的构造方法
- Spvmn测试环境搭建及其安全性讨论
- ENSP模拟华为USG6000
- kaggle竞赛入门整理
- Linux sort命令详解
- 20155204 王昊《网络对抗技术》EXP3
- Adaboost公式推导
- 2115: [Wc2011] Xor
- C# 键盘记录器
- ZeptoLab Code Rush 2015 A. King of Thieves 暴力
- MySQL在线加字段实现原理