import asyncio
 
NUM_WORKERS = 3
 
 
async def ask(q):
    while True:
        res = input('Enter data: ')
        await q.put(res)
        await asyncio.sleep(0.1)
 
 
async def produce(q):
    while True:
        elem = await q.get()  # ждем элемент
        print(f'Processing {elem} ...')
        await asyncio.sleep(3)  # симуляция асинхронной обработки
        print(f'{elem} done')
 
 
async def main():
    queue = asyncio.Queue()
    print('Main started')
    for _ in range(NUM_WORKERS):  # запускаем сразу несколько асинхронных воркеров
        asyncio.create_task(produce(queue))    
    await ask(queue)
 
 
if __name__ == '__main__':
    asyncio.run(main())
 

aW1wb3J0IGFzeW5jaW8KCk5VTV9XT1JLRVJTID0gMwoKCmFzeW5jIGRlZiBhc2socSk6CiAgICB3aGlsZSBUcnVlOgogICAgICAgIHJlcyA9IGlucHV0KCdFbnRlciBkYXRhOiAnKQogICAgICAgIGF3YWl0IHEucHV0KHJlcykKICAgICAgICBhd2FpdCBhc3luY2lvLnNsZWVwKDAuMSkKCgphc3luYyBkZWYgcHJvZHVjZShxKToKICAgIHdoaWxlIFRydWU6CiAgICAgICAgZWxlbSA9IGF3YWl0IHEuZ2V0KCkgICMg0LbQtNC10Lwg0Y3Qu9C10LzQtdC90YIKICAgICAgICBwcmludChmJ1Byb2Nlc3Npbmcge2VsZW19IC4uLicpCiAgICAgICAgYXdhaXQgYXN5bmNpby5zbGVlcCgzKSAgIyDRgdC40LzRg9C70Y/RhtC40Y8g0LDRgdC40L3RhdGA0L7QvdC90L7QuSDQvtCx0YDQsNCx0L7RgtC60LgKICAgICAgICBwcmludChmJ3tlbGVtfSBkb25lJykKCgphc3luYyBkZWYgbWFpbigpOgogICAgcXVldWUgPSBhc3luY2lvLlF1ZXVlKCkKICAgIHByaW50KCdNYWluIHN0YXJ0ZWQnKQogICAgZm9yIF8gaW4gcmFuZ2UoTlVNX1dPUktFUlMpOiAgIyDQt9Cw0L/Rg9GB0LrQsNC10Lwg0YHRgNCw0LfRgyDQvdC10YHQutC+0LvRjNC60L4g0LDRgdC40L3RhdGA0L7QvdC90YvRhSDQstC+0YDQutC10YDQvtCyCiAgICAgICAgYXN5bmNpby5jcmVhdGVfdGFzayhwcm9kdWNlKHF1ZXVlKSkgICAgCiAgICBhd2FpdCBhc2socXVldWUpCgoKaWYgX19uYW1lX18gPT0gJ19fbWFpbl9fJzoKICAgIGFzeW5jaW8ucnVuKG1haW4oKSkK