# 1. 协程队列
由于协程为单线程推动的, 所以协程队列之间可以不需要进行特殊处理即可通讯,
* 所以可以直接用`list`代替.
* 也可以使用`gevent.Queue`
## 1.1 `gevent`
协程队列, 原理使用双端队列`collections.deque`实现.
```python
def __init__(self, maxsize=None, items=(), _warn_depth=2):
return Queue
```
* maxsize: `int`, 队列容纳上限
* items: `tuple`, 队列初始化数据
* _warn_depth: `int`, 如果`maxsize=0`, 是否发出警告, 2以上表示不警告, 以下表示警告
**示例**
```python
import time
import gevent
from gevent.monkey import patch_all
from gevent.queue import Queue
from gevent.pool import Pool
patch_all()
def demo1(q):
i = 0
while True:
q.put(i)
if i == 20:
break
i += 1
def demo2(q):
while True:
print(q.get())
time.sleep(1)
if q.empty() is True:
break
print("over")
if __name__ == "__main__":
q = Queue(2)
# g1 = gevent.spawn(demo1, q)
# g2 = gevent.spawn(demo2, q)
# g3 = gevent.spawn(demo2, q)
# g1.start()
# g2.start()
# g3.start()
# g1.join()
# g2.join()
"""池"""
pool = Pool(10)
pool.apply_async(demo1, args=(q,))
pool.apply_async(demo2, args=(q,))
pool.apply_async(demo2, args=(q,))
pool.join()
```
## 1.2 使用list
由于协程是通过单线程实现的, 容器对象(`list`, `dict`, `set`)时全局通用的, 所以可以使用这些容器代替队列进行操作
**示例(list)**
```python
imp
