Using async functions in mutliprocessing

async_mutliprocessing.py

import asyncio
from concurrent.futures import ProcessPoolExecutor, as_completed

async def func():
    pass

def process_main(*args, **kwargs):
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    loop.run_until_complete(func(*args, **kwargs))

if __name__ == '__main__':
    with ProcessPoolExecutor(num_processes) as executor:
        futures = [executor.submit(process_main) for i in range(num_processes)]
        for f in as_completed(futures):
            f.result()