Metadata-Version: 2.1
Name: aio-parallel-tools
Version: 0.0.1
Summary: simple tools
Home-page: https://python-tools.github.io/aio_parallel_tools/
Author: huangsizhe
Author-email: hsz1273327@gmail.com
License: MIT
Keywords: tools,asyncio
Platform: UNKNOWN
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: MIT License
Classifier: Programming Language :: Python :: 3.7
Classifier: Programming Language :: Python :: 3.8
Classifier: Topic :: Documentation :: Sphinx
Provides-Extra: dev
Requires-Dist: wheel ; extra == 'dev'
Requires-Dist: pep8 ; extra == 'dev'
Requires-Dist: autopep8 ; extra == 'dev'
Requires-Dist: mypy ; extra == 'dev'
Requires-Dist: pydocstyle ; extra == 'dev'
Requires-Dist: mypy-extensions ; extra == 'dev'
Requires-Dist: coverage ; extra == 'dev'
Requires-Dist: lxml ; extra == 'dev'
Requires-Dist: recommonmark ; extra == 'dev'

Welcome to aio parallel tools's documentation!
==============================================

* version: 0.0.1
* status: dev
* author: huangsizhe
* email: hsz1273327@gmail.com


Desc
--------------------------------

Tools for creating asynchronous scripts easily.

keywords: tools,asyncio


Feature
----------------------
* Task pool 
* Actor and Actor Manager


Example
^^^^^^^^^^^^^^^^^^^

.. code:: python

    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)


Install
--------------------------------
- ``python -m pip install aio_parallel_tools``



Document
-------------------

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

Change Log
------------------

version 0.0.1
^^^^^^^^^^^^^^^^^^^

* created this project

