asyncio_workers.py

from concurrent.futures import ProcessPoolExecutor
import asyncio
import signal
import sys


def worker(wid):

    def handler(signum, frame):
        print("Exit signal in worker {}".format(wid))

    signal.signal(signal.SIGINT, handler)
    signal.signal(signal.SIGTERM, handler)

    signal.pause()



async def run_workers(count):

    loop = asyncio.get_event_loop()

    futures = []
    print("Starting work")
    for i in range(count):
        fut = loop.run_in_executor(None, worker, i)
        futures.append(fut)

    print("All work submitted")
    await asyncio.wait(futures)




if __name__ == '__main__':

    executor = ProcessPoolExecutor(max_workers=10)
    loop = asyncio.get_event_loop()
    loop.set_default_executor(executor)

    def handler():
        executor.shutdown()
        loop = asyncio.get_event_loop()
        print("main exit signal recieved")
#        loop.stop()


    loop.add_signal_handler(signal.SIGINT, handler)

    print("Running until complete")
    loop.run_until_complete(asyncio.ensure_future(run_workers(10)))
    print("Running completed")

    loop.close()