友好的contextvars ThreadPoolExecutor
项目描述
- info:
友好的contextvars ThreadPoolExecutor
安装
pip install contextvars_executor
为什么???
使用方法
import asyncio
import contextvars
from contextvars_executor import ContextVarExecutor
ctx = contextvars.ContextVar('42')
def thread():
ret = ctx.get()
assert ret == 42
return ret
async def main(*, loop):
ctx.set(42)
ret = await loop.run_in_executor(None, thread)
assert ret == 42
loop = asyncio.get_event_loop()
loop.set_default_executor(ContextVarExecutor())
loop.run_until_complete(main(loop=loop))
需要Python 3.7+,无需支持较旧的Python版本!!!
项目详情
关闭
contextvars_executor-0.0.1.tar.gz的哈希
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 7a47c1e8c29cbdb9006dae5d03be7fd329b5585fe8f0b62e0cd94eaf4db741bd |
|
MD5 | c00f01668a801500e77f325e093eee48 |
|
BLAKE2b-256 | 2ab7b465571636dfd2ae00f26a8647183e9d97ea2daca790347db5c27a4ec423 |