A concurrent.futures.Executor implementation that runs asynchronous tasks in an asyncio event loop.
Project description
aio-executor
A concurrent.futures.Executor implementation that runs asynchronous tasks in an asyncio loop.
Example usage:
from aio_executor import AioExecutor async def my_async_function(arg): # ... with AioExecutor() as aioexec: # single invocation f = aioexec.submit(my_async_function, 'foo') result = f.result() # multiple concurrent invocations using "map" results = aioexec.map(my_async_function, ['foo', 'bar', 'baz'])
As a convenience, a run_with_asyncio
decorator is also provided. This
decorator runs the decorated async function in a AioExecutor
instance.
The example below shows how to implement an async view function for the Flask framework using this decorator:
@app.route('/') @run_with_asyncio async def index(): return await get_random_quote()
How to Install
pip install aio-executor
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Filename, size | File type | Python version | Upload date | Hashes |
---|---|---|---|---|
Filename, size aio_executor-0.2.0-py2.py3-none-any.whl (3.5 kB) | File type Wheel | Python version py2.py3 | Upload date | Hashes View |
Filename, size aio-executor-0.2.0.tar.gz (2.6 kB) | File type Source | Python version None | Upload date | Hashes View |
Close
Hashes for aio_executor-0.2.0-py2.py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 06ddbd83f2056435a0e9aac83b9d1a7a6d74142bfdec456d03d28c4428a8fdf9 |
|
MD5 | 2e06a106ed98f01dbb05429df25dafd4 |
|
BLAKE2-256 | f91bcab73482f931a4d73bba8d85fda6bd0e067801b0db2fda152656f9315e28 |