《Go语言编程》一书介绍了libtask库,可以认为这个库等同于go的底层goroutine实现。
libtask库的channel的数据结构如下:
1struct Alt
2{
3Channel *c;
4void *v;
5unsigned int op;
6Task *task;
7Alt *xalt;
8};
9struct Altarray
10{
11Alt **a;
12unsigned int n;
13unsigned int m;
14};
15struct Channel
16{
17unsigned int bufsize;
18unsigned int elemsize;
19unsigned char *buf;
20unsigned int nbuf;
21unsigned int off;
22Altarray asend;
23Altarray arecv;
24char *name;
25};
我们可以看到channel的基本组成如下:
内存缓存,用于存放元素;
发送队列;
接受队列。
书中罗列完channel的结构后没有深入讲解如何在channel这个结构上进行通信的过程。其实结合书中前面介绍的内容task(协程)的通信过程已经不言而明了。
但是从学习者的角度,当然是把这个问题讲解的越明白越好。接下来我试着介绍一下task(协程)是如何在这个channel的基础上通信的。
对于一个往channel里写数据的情况:
对于一个从channel里读数据的情况:
注意:以上两个流程都是基于书中对协程的工作原理和channel数据结构的介绍后我个人脑补的,并没有去翻看libtask的代码。很可能存在疏漏,只应当把这两个流程作为理解协程工作方式的参照。