golang中最大协程数的限制(线程)

Python010

golang中最大协程数的限制(线程),第1张

golang中最大协程数的限制 golang中有最大协程数的限制吗?如果有的话,是通过什么参数控制呢?还是通过每个协程占用的资源计算? 通过channel控制协程数的就忽略吧。以我的理解,计算机资源肯定是有限的,所以goroutine肯定也是有限制的,单纯的goroutine,一开始每个占用4K内存,所以这里会受到内存使用量的限制,还有goroutine是通过系统线程来执行的,golang默认最大的线程数是10000个。可以通过https://gowalker.org/runtime/debug#SetMaxThreads 来修改。但要注意线程和goroutine不是一一对应关系,理论上内存足够大,而且goroutine不是计算密集型的话,可以开启无限个goroutine。 https://gowalker.org/runtime/debug#SetMaxThreads

【译文】 原文地址

本文基于go 1.13版本

所有在Go中创建的goroutines都由一个内部调度程序的管理。Go调度程序试图给所有的goroutines分配运行时间,并且在当前goroutine被阻塞或终止情况下也能使CPU忙于运行其他goroutines。

Go通过GOMAXPROCS变量来限制操作系统线程同时运行的数量。这意味着,Go必须在每个正在运行的线程上调度和管理所有的goroutines。这个角色通过一个特殊的goroutine来完成,称为g0,这是为每个操作系统线程创建的第一个goroutine:

当goroutine被阻塞在channel上时,当前的goroutine就会被挂起,即处于等待模式将不会推入任何goroutines队列中。

收到消息的goroutine将切换到g0,然后将挂起的goroutine放入到本地调度队列中:

尽管g0这个特殊goroutine是管理调度的,但是它不止这些工作还有其他更多的功能。

与普通goroutine相反,g0有固定且比较大的栈。这允许Go在需要更大栈时,还能执行操作。g0的职责可以如下:

有以下方法:

方法一:使用带有缓冲的channel的特性

直到缓冲区被填满后,写端才会阻塞。

缓冲区被读空,读端才会阻塞。

代码中channel数据结构为什么定义struct?

因为空结构体变量的内存占用大小为0,而bool类型内存占用大小为1,这样可以更加最大化利用我们服务器的内存空间。

方法二:使用sync.WaitGroup

WaitGroup对象内部有一个计数器,最初从0开始,它有三个方法:Add(),Done(),Wait()用来控制计数器的数量。