专栏简介在这个专栏中我将会分享

Goroutine它们都需要不断地从一个共享的队列中获取任务进行处理。

为了提高并发效率我们可以使用

GMP

都会不断地尝试从全局队列中获取任务并将其添加到自己的本地队列中执行。

当某个

Goroutine

模拟处理任务的耗时time.Sleep(time.Second)//

交出任务使用

运行多长时间如果你不主动让出对不起我有手段可以抢占你把你踢出去让后面的

goroutine

runtime.morestack让运行时有机会在这段代码中检查是否需要执行抢占调度。

Goroutine

{}}()time.Sleep(time.Second)fmt.Println(I

got

版本中增加了对非协作的抢占式调度的支持这种抢占式调度是基于系统信号的也就是通过向线程发送信号的方式来抢占正在运行的

cpu

是无法抢占执行的。

这样可以避免出现线程安全的问题但也会导致某个

Goroutine

执行时间过长时会在指定时间内收到一个抢占信号然后在信号处理程序中暂停当前

Goroutine

语言的系统线程中生效而在非系统线程中仍然采用协作式调度。

这是因为非系统线程是由

语言运行时管理的无法被操作系统直接抢占因此只能采用协作式调度。

另外抢占式调度对于需要实现低延迟的应用程序可能不太适合因为抢占操作需要额外的

CPU

running)time.Sleep(time.Second)}}()go

func()

running)time.Sleep(time.Second)}}()for

{fmt.Println(Main

running)time.Sleep(time.Second)}

“Goroutine

需要注意的是抢占式调度并不是默认启用的如果要启用抢占式调度可以通过设置

GOMAXPROCS