asyncio FIFO

async_fifo.py

import asyncio

async def testProc():
  for i in range(10):
    await asyncio.sleep(1)
    print("sleep")

def callbackProc():
  #print("Callback event")
  loop = asyncio.get_event_loop()
  loop.call_soon(callbackProc)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    try:
        print('task creation started')
        asyncio.ensure_future(testProc())
        loop.call_soon(callbackProc)
        loop.run_forever()
    finally:
        loop.close()