- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Go语言中的并发goroutine底层原理由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
1.概念 。
2.图解 。
类似于超市柜台结账,并行是多个柜台结多个队列,在计算机中是多核cpu处理多个go语言开启的线程,并发是一个柜台结账多个队列,在计算机中就是单核cpu处理多个任务,抢夺时间片. 。
1.用户态线程、内核态线程差异 。
2.java与go并发差异:
java
go
1.历史背景 。
Go语言产生较晚,在其产生之前就已经有了多核cpu,所以设计者的理念就是将这门新的语言使用到多核cpu上支持更大数量级的并发 。
2.自身原因 。
Go语言多并发底层实现使用的是协程,他占有更少的资源具有更快的执行速度,占用的资源还会根据 任务量进行扩大或者缩小 。
1. G: G是Goroutine的缩写,在这里就是Goroutine的控制结构,是对Goroutine的抽象。其中包括执行的函数指令及参数;G保存的任务对象;线程上下文切换,现场保护和现场恢复需要的寄存器(SP、IP)等信息。在 Go 语言中使用 runtime.g 结构表示.
2. M
表示操作系统线程也可以称为内核线程,由操作系统调度以及管理,调度器最多可以创建 10000 个线程,在 Go 语言中使用 runtime.m 结构表示。(用户线程与内核线程的映射关系) 。
3. P
调度各个goroutine,使他们之间协调运行逻辑处理器,但不代表真正的CPU的数量,真正决定并发程度的是P,初始化的时候一般会去读取GOMAXPROCS对应的值,如果没有显示设置,则会读取默认值,在Go1.5之后GOMAXPROCS被默认设置可用的核数,而之前则默认为1,在 Go 语言中使用 runtime.p 结构表示.
4.指定cpu线程个数 。
通过runtime.GOMAXPROCS(),可以指定P的个数,如果没有指定则默认跑满整个cpu 。
开启线程使用go+函数,以下案例要认识到开启多线程使用函数闭包可能会出现的问题 。
1.使用匿名函数开启线程 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
//
打印1-1000
for
i := 0; i < 1000; i++ {
go func() {
fmt
.Println(i)
}()
}
//
这里使用了函数闭包
/*
打印结果
995
995
995
996
996
999
1000
1000
*/
|
2.出问题的原理:
匿名函数进行操作时会将当前环境内的变量进行闭包,由于启动线程需要一定时间在启动线程的时候i进行了改变所以打印的时候会有许多值相同 。
1.为什么需要进行动态的关闭线程?
在Go语言中如果不进行动态的关闭线程,那么有可能在子线程没有执行结束主线程就结束了,那样的话会有 程序安全隐患,所以主线程不可以直接结束,应作为后盾,直到所有线程都结束了才可以结束.
2.使用waitGroup 。
waitGroup有三个方法常用:
waitGroup.Add()
:使用wait计数器记1次数//将创建的线程数传进去 waitGroup.Done()
:wait计数器减1(放在被开启线程的函数内)waitGroup.Wait()
:阻塞等待wait计数器值为零(放在主线程内)defer是在函数主体执行完的时候执行的代码(可理解为延时执行) 。
代码如下:
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
|
package main
import
(
"fmt"
"math/rand"
"sync"
"time"
)
//
定义一个waitGroup结构体变量
var wg
sync
.WaitGroup
func f(i int) {
//
等到函数执行完毕,会将waitGroup内的计数器减一
defer wg.Done()
rand.Seed(
time
.Now().UnixNano())
time
.Sleep(
time
.Duration(rand.Intn(3)) *
time
.Second)
fmt
.Println(i)
}
func main() {
for
i := 0; i < 100; i++ {
//
开启一个线程就使用waitGroup记一次数
wg.Add(1)
go f(i)
}
//
阻塞等待waitGroup计数器为0
wg.Wait()
fmt
.Println(
"hello"
)
}
|
总结: Go语言的高并发奠定了其未来在高级语言中的地位,越来越多的用户加入互联网需要一个支持高并发语言的支持,亿万级电商秒杀,亿万级游戏用户同时在线都离不开这样的语言,所以Go语言一直被游戏后端、web后端项目开发者青睐.
到此这篇关于Go语言中的并发goroutine底层原理的文章就介绍到这了,更多相关Go语言中的并发goroutine内容请搜索我以前的文章或继续浏览下面的相关文章希望大家以后多多支持我! 。
原文链接:https://blog.csdn.net/apple_51931783/article/details/122519930 。
最后此篇关于Go语言中的并发goroutine底层原理的文章就讲到这里了,如果你想了解更多关于Go语言中的并发goroutine底层原理的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
发件人:http://blog.nindalf.com/how-goroutines-work/ As the goroutines are scheduled cooperatively, a go
很多时候在用 Go 开发 http 服务器时,我都会遇到这种困境。 假设我想尽快用http statuscode 200响应客户端(然后在后面执行工作),这就是我通常这样做的原因: 我让我的主要 ht
这是代码: import "fmt" func main() { messages := make(chan string, 1) go func(c chan string) {
我正在学习 Golang,但遇到了一些困难。我已经研究过 Google,但没有任何进展。 我编写了一个代码,通过多台服务器的 ICMP 检查 RTT。 它有这样的结构: type Server str
我想运行多个 goroutine,进行一些处理,将结果放入 channel ,当至少有一个 goroutine 完成时,完成所有其他 goroutine 并从 channel 返回结果。 所以,我尝试
我有两个(但以后我会是三个)go 例程来处理来自远程服务器(来自 ampq channel )的传入消息。但是因为它们正在处理相同的数据/状态,所以我想阻止所有其他 go 例程,除了正在运行的例程。
我有一个案例,我从 2 个不同的位置(ES 和 REDIS)读取数据,我需要从最快的源读取一个值,因此我触发了 2 个 goroutines,一个从 ES 获取数据,其他从REDIS获取。 一旦从其中
像这里一样,我创建了一个 go playground 示例:sGgxEh40ev ,但无法正常工作。 quit := make(chan bool) res := make(chan int) go
我是golang的新手,正在研究goroutine。 我写了一个简单的代码,故意使用 goroutine 来划分数字。 首先,我给出基数并继续除它的数,直到它不能被整除 但是,我改变了go split
Main { go routine_1(carryout a time consuming task and return output) go routine_2(wait for output f
我想知道从另一个 goroutine 返回时调用的 goroutine 会发生什么。他们是继续运行还是被终止?这是一个示例代码来说明我的意思: func func() { // Doing s
更具体地说,在我的例子中,我有一个网络服务器和一个全局可访问的结构,网络服务器使用它来生成页面。我有另一个 Goroutine,它总是定期用新值更新该结构。这会引起问题吗?我是否需要实现一种机制来确保
来自 this file ,我不明白为什么函数startWorker会这样写: func (p *WorkerPool) dispatch() { for i := 0; i < p.maxW
我正在学习围棋,但在使用 goroutines 时遇到了问题。这是我的代码 package main import ( "fmt" "sync" "time" ) var co
我收到以下错误,我不明白为什么: 发送:查询 Herefatal 错误:所有 goroutines 都睡着了 - 死锁! 您可以看到我正在调用我使用 goroutine 创建的函数 routine。我
大家好,我正在从 Python3 过渡到 Go,所以我正在尝试重写我创建的库以获得更好的性能。 我面临一个问题,因为我是 Golang XD 中的新手,我使用有限的 API 下载数百个 json,我想
我有以下格式的脚本部分: func main() { for i=0;i<1000000;i++ { go test() } } func test() { a := test
package main func main() { c:=make(chan int) for i:=0; i<=100;i++ {
我正在学习 Go,我的第一个项目是一个简单的 ping 脚本。本质上,我想 ping 一堆 url,并在每个响应时等待 XXX 秒,然后再次 ping。这是删减的代码: func mai
这个问题在这里已经有了答案: Go all goroutines are asleep deadlock (2 个回答) fatal error: all goroutines are asleep
我是一名优秀的程序员,十分优秀!