Run your coroutines and functions in child process or thread like the way using concurrent.futures.
Aplex is a Python library for combining asyncio with multiprocessing and threading.
- Aplex helps you run coroutines and functions in other process or thread with asyncio.
- Aplex provides a usage like that of standard library
concurrent.futures, which is familiar to you and intuitive.
- Aplex lets you do load balancing in a simple way if you need.
For general users, use the package manager pip to install aplex.
pip install aplex
For contributors, install with pipenv:
git clone https://github.com/lunluen/aplex.git cd aplex pipenv install --dev
or with setuptools
git clone https://github.com/lunluen/aplex.git cd aplex python setup.py develop
Definition to know:
callableyou want to run with asyncio and multiprocessing or threading. It can be a coroutine function or just a function.
In below case, the
work is the coroutine function
You can submit your work like:
import aiohttp from aplex import ProcessAsyncPoolExecutor async def demo(url): async with aiohttp.request('GET', url) as response: return response.status if __name__ == '__main__': pool = ProcessAsyncPoolExecutor(pool_size=8) future = pool.submit(demo, 'http://httpbin.org') print('Status: %d.' % future.result())
Note: If you are running python on windows,
if __name__ == '__main__':
is necessary. That's the design of multiprocessing.
For multiple works, try
iterable = ('http://httpbin.org' for __ in range(10)) for status in pool.map(demo, iterable, timeout=10): print('Status: %d.' % status)
Aplex allows one to await results with loop that already exists. It's quite simple.
Just set keyword argument
pool = ProcessAsyncPoolExecutor(awaitable=True)
future = pool.submit(demo, 'http://httpbin.org') status = await future
How about map?
async for status in pool.map(demo, iterable, timeout=10): print('Status: %d.' % status)
In aplex, each worker is the process or thread on your computer. That is, they have the same capability computing. But, your works might have different workloads. Then you need a load balancer.
Aplex provides some useful load balancers. They are
Average. The default is
Simply set this in contruction keyword argument:
from aplex.load_balancers import Average if __name__ == '__main__': pool = ProcessAsyncPoolExecutor(load_balancer=Average)
Done. So easy. :100:
You can also customize one:
from aplex import LoadBalancer class MyAwesomeLoadBalancer(LoadBalancer): def __init__(*args, **kwargs): super().__init__(*args, **kwargs) # Don't forget this. awesome_attribute = 'Hello Aplex!' def get_proper_worker(self): the_poor_guy = self.workers return the_poor_guy
Worker loop factory
By the way, if you think the build-in asyncio loop is too slow:
import uvloop if __name__ == '__main__': pool = ProcessAsyncPoolExecutor(worker_loop_factory=uvloop.Loop)
Scroll up and click
Watch - Releases only and
Star as a thumbs up! :+1:
Feel free to open a issue (just don't abuse it).
Or contact me:
Anything about aplex is welcome, such like bugs, system design, variable naming, even English grammer of docstrings!
How to contribute
Contribution are welcome.
Asking and advising are also kinds of contribution.
Please see CONTRIBUTING.md
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Hashes for aplex-1.0.1-py2.py3-none-any.whl