Сопрограмма для обработчика запросов

@asyncio.coroutine
def slow_operation(future):
    yield from asyncio.sleep(1)  # тут долгий запрос
    future.set_result('Future is done!')
 
loop = asyncio.get_event_loop()
future = asyncio.Future()
asyncio.ensure_future(slow_operation(future))
loop.run_until_complete(future)
print(future.result())

loop.run_until_complete(future)

@asyncio.coroutine
def обработчик(reader, writer):
    ...
 
loop = asyncio.get_event_loop()
server_coro = asyncio.start_server(обработчик, host, port)
server = loop.run_until_complete(server_coro) # вернется сразу же. Вернет asyncio.Server
try:
    loop.run_forever() # будет вечно обрабатывать запросы
finally:
    server.close()
    loop.close()

@asyncio.coroutine
def slow_operation():
    yield from asyncio.sleep(10)  # request to another server
    print('Future is done!')
 
def add():
    while True:
        time.sleep(1)
        asyncio.run_coroutine_threadsafe(slow_operation(), loop)
 
loop = asyncio.get_event_loop()
th.Thread(target=add).start()
loop.run_forever()