概述
channel是goroutine之间的通信机制,同时,channel也是实现复杂高并发程序的基础。在这里会对channel内部的工作机制,包括channel如何被调度器调度、内存管理系统等进行深入的说明。
我们可以用channel实现一个简单的任务队列。
channel 具有如下特性:
- channel 是goroutine安全的。
- channel 可以在goroutine 之间传递消息。
- 遵循FIFO语法
- channel 可以是阻塞或者非阻塞的。
创建 channel
在使用之前首先要创建一个channel,make可以创建带缓冲区或者不带缓冲区的channel。这里主要讨论的是带有缓冲区的channel。
创建一个缓冲区容量为3的channel,ch := make(chan Task, 3)
- 这个channel是goroutine安全的。
- 存储到channel中的数据是遵循FIFO的。
- 可以在goroutine之间传输消息。
- 能够使goroutine阻塞或者非阻塞。
make chan 在堆内存上创建了一个hchan结构,返回指向它的指针。这使得我们可以在方法之间传递channel。
使用 channel
channel是怎样发送和接收消息的?
- G1发送任务,G2接收并执行任务。
- 首先,G1向channel中发送任务,将任务写入队列的这个过程是需要锁的。入队的值实际上是原值的一个拷贝。
- 接着,G2做相反的工作:将任务出队。这个过程也是需要锁的,同样的,出队的值实际上也是原值的一个拷贝。
- 每次操作时,操作的都是值的拷贝保证了goroutine安全,操作的过程channel是加锁的保证了互斥。
channel的阻塞和非阻塞是怎样工作的?
假设G1不停的向channel中发送任务,同时G2处理任务需要花费一些时间。当channel满了的时候,G1就会暂停执行。G1是怎么暂停的呢?
它是由runtime 调度器来实现的。
Goroutine 是Go runtime创建和管理的用户级别线程,而不是由系统来管理的。这些线程和系统线程相比更加轻量级。
Go语言调度器是一个M:N的调度器,将少部分系统线程映射到N个goroutine上,调度器的任务就是调度goroutine,让其运行在少数的系统线程上。
暂停 goroutine
当goroutine需要暂停的时候,调度器在接收到chan的通知后,将G1从running状态置为waiting状态,同时调度其它goroutine使用空出来的系统线程。
这个做法非常好,因为我们并没有停止系统线程的运行,只是通过上下文切换的方式更换了正在运行的goroutine,这个操作的代价很小。
当channel又有存储空间的时候,我们需要将这个goroutine从暂停的状态上恢复回来。
恢复 goroutine
处于等待状态的goroutine结构中有一个指针,指向它正在等待的元素?
G1自己创建了一个sudog,将它放入到channel的等待队列中,用于在以后恢复G1的运行。
当channel又存在存储空间的时候,G2需要将sudog出队,这时G1又会被恢复运行。runtime 调度器再一次调度G1,恢复G1的运行。(这也解释了G2被暂停和恢复的原因。)
直接发送
当G1真正运行的时候,它首先要获取锁,但是runtime 更加机智,在此做了优化。runtime可以直接将值拷贝到接收者的栈内存。 G1直接写G2的栈内存,这个过程并不需要锁;G2在读取的时候也不再需要channel锁而直接去操作缓存,这样节省了值拷贝的内存空间。