aio_process_pool 0.0.2

An async, concurrent.futures.Executor compliant, android compatible process pool implementation

aio_process_pool

---

Tihs pacakage provides an async, concurrent.futures.Executor compliant, android compatible process pool.

Table of Contents

• Installation
• Usage
• License

Installation

pip install aio_process_pool

Usage

from aio_process_pool import AsyncProcessPool


def foo(x):
    return x


# Note:
# - the process pool must be initialize AFTER all functions that are supposed
#   to be called are defined
# - it's not save to initialize a process pool from a multithreaded process
#   because it's based on `os.fork` / `multiprocessing.Process`
pool = AsyncProcessPool()


async def using_run():
    return await pool.run(foo, 72)


async def using_submit():
    future = pool.submit(foo, 73)
    return await future


async def using_executor():
    from functools import partial

    loop = asyncio.get_event_loop()
    return await loop.run_in_executor(pool, partial(foo, 74))

License

aio_process_pool is distributed under the terms of the MIT license.