Search code examples
pythonasynchronouspython-asynciocoroutineparallels

async server code in python wont work when using asyncio.start_server


This is async python, but won't work when I sending requests to it and use time.sleep(5) for test of parallel, but it's sequential and requests executed sequentially:

def main(*args):    
    loop = get_event_loop()

    coro = asyncio.start_server(handle_echo, '127.0.0.1', 50008,loop=loop)
    srv = loop.run_until_complete(coro)   
def handle_echo(reader, writer):
    data = yield from reader.read(500)
    message = data.decode(encoding='utf-8')            

    nameindex=('name="calculator2"' in message)
    if nameindex:
        time.sleep(5)
        writer.write("Content-Length: 1\r\n\r\n2".encode())
        yield from writer.drain()
    else:
        writer.write("Content-Length: 1\r\n\r\n1".encode())
        yield from writer.drain()

    print("Close the client socket")
    writer.close()

Solution

  • replace:

    time.sleep(5)
    

    with:

    await asyncio.sleep(5)