一组用于处理管道的通用协同程序。
coroutines的Python项目详细描述
#coroutines
一组用于处理管道的通用coroutines。
`` python
导入coroutine s
@coroutines.coroutine
def myocroutine():
如果为真:
s=yield
做一些事情
```
生产者
-平凡的生产者将永远发送同样的东西!
-CycleProducer将循环发送无限循环中的项目。
-FileProducer将打开()文件并逐行发送。
-FiniteProducer只发送有限计数的项目。
-limitedconsumer将只使用指定数量的项。
-consumer to buffer将使用缓冲区。
您可以在缓冲区达到指定大小时让consumer()停止,或者使用
bufferedconsumer()无限期地使其缓冲。无论哪种方式,您都可以使用output()获取并重置缓冲区
匹配项可以发送到一个使用者和/或不匹配项可以发送到另一个使用者
一组用于处理管道的通用coroutines。
`` python
导入coroutine s
@coroutines.coroutine
def myocroutine():
如果为真:
s=yield
做一些事情
```
生产者
-平凡的生产者将永远发送同样的东西!
-CycleProducer将循环发送无限循环中的项目。
-FileProducer将打开()文件并逐行发送。
-FiniteProducer只发送有限计数的项目。
-limitedconsumer将只使用指定数量的项。
-consumer to buffer将使用缓冲区。
您可以在缓冲区达到指定大小时让consumer()停止,或者使用
bufferedconsumer()无限期地使其缓冲。无论哪种方式,您都可以使用output()获取并重置缓冲区
匹配项可以发送到一个使用者和/或不匹配项可以发送到另一个使用者