跳转到主要内容

友好的contextvars ThreadPoolExecutor

项目描述

info:

友好的contextvars ThreadPoolExecutor

https://travis-ci.org/hellysmile/contextvars_executor.svg?branch=master https://img.shields.io/pypi/v/contextvars_executor.svg https://codecov.io/gh/hellysmile/contextvars_executor/branch/master/graph/badge.svg

安装

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 (2.2 kB 查看哈希)

上传时间: 源代码

由以下支持