Skip to main content

Run your coroutines and functions in child process or thread like the way using concurrent.futures.

Project description


build coverage platform supported pythons package version license maintenance

Translation: 简体中文 | 繁體中文

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
cd aplex
pipenv install --dev

or with setuptools

git clone
cd aplex
python develop


Definition to know:

A work is a callable you 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 demo.


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, '')
    print('Status: %d.' % future.result())

Note: If you are running python on windows, if __name__ == '__main__': is necessary. That's the design of multiprocessing.


Status: 200


For multiple works, try map:

iterable = ('' for __ in range(10))
for status in, iterable, timeout=10):
    print('Status: %d.' % status)

Awaiting results

Aplex allows one to await results with loop that already exists. It's quite simple.

Just set keyword argument awaitable to True!

For example:

pool = ProcessAsyncPoolExecutor(awaitable=True)


future = pool.submit(demo, '')
status = await future

How about map?

async for status in, iterable, timeout=10):
    print('Status: %d.' % status)

Load balancing

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 RoundRobin, Random, and Average. The default is RoundRobin.

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[0]
        return the_poor_guy

See details of how to implement a load balancer at:

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)

Like this?

Scroll up and click Watch - Releases only and Star as a thumbs up! :+1:

Any feedback?

Feel free to open a issue (just don't abuse it).

Or contact me: :mailbox:

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



Project details

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

aplex-1.0.1.tar.gz (500.7 kB view hashes)

Uploaded source

Built Distribution

aplex-1.0.1-py2.py3-none-any.whl (35.1 kB view hashes)

Uploaded py2 py3

Supported by

AWS AWS Cloud computing Datadog Datadog Monitoring Facebook / Instagram Facebook / Instagram PSF Sponsor Fastly Fastly CDN Google Google Object Storage and Download Analytics Huawei Huawei PSF Sponsor Microsoft Microsoft PSF Sponsor NVIDIA NVIDIA PSF Sponsor Pingdom Pingdom Monitoring Salesforce Salesforce PSF Sponsor Sentry Sentry Error logging StatusPage StatusPage Status page