0

Как сделать так, чтобы корутина выполнялась в фоне, и не задерживала код?

import socket
import asyncio


async def test():
    print("hi")
    await asyncio.sleep(2)
    print("bye")


async def main():
    with socket.create_server(("localhost", 6666)) as server:
        loop = asyncio.get_event_loop()

        while True:
            client, _ = await loop.sock_accept(server)
            mess = await loop.sock_recv(client, 1024)
            print(mess.decode())
            client.close()
            
            asyncio.create_task(test())

if __name__ == '__main__':
    asyncio.run(main())

Есть вот такой небольшой тестовый скрипт, тут две функции... Использую socket.

Я хочу чтобы asyncio.create_task(test()) выполнилась и не задерживала код. То есть сделала как бы "новый поток" в стиле asyncio и там эта задача выполнилась. Только как это сделать - не знаю...

1 ответ 1

1

ну и по классике жизни, сам написал - сам ответил....


import socket
import asyncio


async def test():
    print("hi")
    await asyncio.sleep(2)
    print("bye")


async def main():
    with socket.create_server(("localhost", 6666)) as server:
        loop = asyncio.get_event_loop()
        server.setblocking(False)

        while True:
            client, _ = await loop.sock_accept(server)
            mess = await loop.sock_recv(client, 1024)
            print(mess.decode())
            client.close()

            asyncio.create_task(test())

if __name__ == '__main__':
    asyncio.run(main())

все дело в server.setblocking(False) и тогда будет работать как надо (по крайней мере как я хочу)

3
  • а почему не испозуешь docs.python.org/3/library/… asyncio.loop.create_server ?
    – eri
    8 июл 2021 в 12:06
  • @eri не удобно использовать...
    – homus32
    8 июл 2021 в 15:08
  • зато можно отрабатывать одновременно несколько подключений в оличие от этого
    – eri
    8 июл 2021 в 15:10

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.