Skip to main content

简单的工具

项目描述

描述

用于轻松创建异步脚本的工具。

关键词:工具,异步

特征

  • 任务池

  • 演员和演员经理

例子

async with AioFixedTaskPoolSimple() as task_pool:
    print(f"test pool size {task_pool.size}")
    print("test 4 task with pool size 3")
    await asyncio.gather(
        task_pool.submit(test, func_args=["c"]),
        task_pool.submit(test, func_args=["b"]),
        task_pool.submit(test, func_args=["a"]),
        task_pool.submit(test, func_args=["d"])
    )

class Pinger(AioActor):
    async def receive(self, message):
        print(message)
        try:
            await ActorManager.get_actor("Ponger").Send('ping')
        except Exception as e:
            print(f"receive run error {e}")
        finally:
            await asyncio.sleep(0.5)

安装

  • python -m pip install aio_parallel_tools

文档

https://python-tools.github.io/aio_parallel_tools/

更改日志

版本 0.0.1

  • 创建了这个项目

项目详情


下载文件

下载适用于您平台的文件。如果您不确定要选择哪个,请了解有关安装包的更多信息。

源分布

aio_parallel_tools-0.0.1.tar.gz (17.2 kB 查看哈希

已上传 source

内置分布

aio_parallel_tools-0.0.1-py3-none-any.whl (37.8 kB 查看哈希

已上传 3 7