asyncio python Example

asyncio.py

import asyncio
import nest_asyncio
nest_asyncio.apply()

async def task(batch_no,roll_no):
    return batch_no,roll_no

async def batch_creator(batch_no):
    result = []
    for roll_no in range(BATCH_SIZE):
        result.append(loop.create_task(task(batch_no,roll_no)))
    return result

async def resCollector():
    for batch_no in range(BATCH_COUNT):
        for m in await batch_creator(batch_no):
            output = await m
            with open('output.txt','a') as f:
                f.write(str(output)+'\n')




loop = asyncio.get_event_loop()
final = asyncio.run(resCollector())
print('Finish Execution')