the note for learning golang
- 全局队列(Global Queue):存放等待运行的G
- P的本地队列:和全局队列类似,存放的也是等待运行的G,存的数量有限,不超过256个。新建G'时,G'优先加入到P的本地队列,如果队列满了,则会把本地队列中一半的G移动到全局队列。
- P列表:所有的P都在程序启动时创建,并保存在数组中,最多有GOMAXPROCS(可配置)个
- M:线程想运行任务就得获取P,从P的本地队列获取G,P队列为空时,M也会尝试从全局队列拿一批G放到P的本地队列,或从其他P的本地队列偷一半放到P的本地队列。M运行G,G执行之后,M会从P获取下一个G,不断重复。
- P的数量
- 由启动时环境变量$GOMAXPROCS或者是由runtime的方法GOMAXPROCS()决定。意味着在程序执行的任意时刻都只有$GOMAXPROCS个goroutine在同时执行
- M的数量
- go语言本身的限制:go程序启动时,会设置M的最大数量,默认10000,但是内核很难支持这么多线程数,所以该限制可以忽略
- runtime/debug中的SetMaxThreads函数,设置M的最大数量
- 一个M阻塞了,会创建新的M
M与P的数量没有绝对关系,一个M阻塞,P就会去创建或者切换到另一个M,所以,即使P的默认数量是1,也有可能会创建多个M出来
- P何时创建:在确定了P的最大数值n后,运行时系统会根据这个数量创建n个P
- M何时创建:没有足够的M来关联P并运行其中的可运行的G。比如所有的M此时都阻塞住了,而P中还以后很多就绪任务,就会去寻找空闲的M,如果没有空闲的,就会去创建新的M
- work stealing机制 当本线程无可运行的G时,尝试从其他线程绑定的P偷取G,而不是销毁线程
- hand off机制 当本线程因为G进行系统调用阻塞时,线程释放绑定的P,把P转移给其他空闲的线程执行 利用并行: GOMAXPROCS设置P的数量,最多有GOMAXPROCS个线程分布在多个CPU上同时运行。GOMAXPROCS也限制了并发的速度,比如GOMAXPROCS = 核数/2,则最多利用了一版的CPU核进行并行 抢占: 在coroutine中要等待一个协程主动让出CPU才执行下一个协程,在Go中,一个goroutine最多占用CPU10ms,防止其他goroutine被饿死,这就是goroutine不同于coroutine的一个地方 全局G队列: 在新的调度器中依然有全局G队列,但功能已经被弱化了,当M执行work stealing从其他P偷不到G时,它可以从全局G队列获取G
当一个goroutine获取读锁以后,其他的goroutine可以继续获取读锁,如果要获取写锁则需要等待; 当一个goroutine获取写锁以后,其他的goroutine无论要获取读锁还是写锁都会等待