asyncio-buffered-pipeline:实用程序函数可并行化Python asyncio迭代器生成器的管道

时间:2024-04-25 18:20:50
【文件属性】:

文件名称:asyncio-buffered-pipeline:实用程序函数可并行化Python asyncio迭代器生成器的管道

文件大小:7KB

文件格式:ZIP

更新时间:2024-04-25 18:20:50

Python

异步缓冲管道 Python异步迭代器/生成器的并行管道。 安装 pip install asyncio-buffered-pipeline 用法/这可以解决什么问题? 如果您具有一串异步生成器,即使每个生成器都是异步的,在任何给定时间都只能运行一个。 例如,下面的内容在30秒内(仅超过30秒)运行。 import asyncio async def gen_1 (): for value in range ( 0 , 10 ): await asyncio . sleep ( 1 ) # Could be a slow HTTP request yield value async def gen_2 ( it ): async for value in it : await asyncio . sleep ( 1 )


【文件预览】:
asyncio-buffered-pipeline-master
----asyncio_buffered_pipeline.py(3KB)
----test.py(7KB)
----.circleci()
--------config.yml(2KB)
----LICENSE(1KB)
----setup.py(790B)
----README.md(3KB)
----.gitignore(2KB)

网友评论