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

Question

[Rudtoha]

Здравствуйте, только начал разбираться с модулем Asyncio, и возникла проблема: есть определенная асинхронная функция, которая что-то делает. Заворачиваю ее в с помощью create_task и отправляю в event loop. Но задача выполняется только один раз, несмотря на то что циклу задаю параметр run_forever.
Для наглядности код:

import asyncio
import time

async def S():
    t = time.time()
    i = 0
    while time.time() - t < 5:
        i += 1
    print("done")

loop = asyncio.get_event_loop()
loop.create_task(S())
loop.run_forever()
loop.close()

Заранее спасибо

Answer 1

[Andrey Dugin]

У вас нет функции, которая требует ожидания ввода-вывода, поэтому asyncio не нужен. Но вот примерный шаблон:

import asyncio
from contextlib import closing

async def get_some_data():
    # Обработка I/O - например, получение данных через HTTP
    await asyncio.sleep(2)
    data = 'ping'
    print(data)
    return data 

async def process(data):
    # Обработка данных на CPU
    await asyncio.sleep(1)    
    print('pong')

async def main():
    while True:
        data = await get_some_data()  # Блокирующий вызов - ожидание поступления новой порции данных
        asyncio.ensure_future(process(data))  # Неблокирующий вызов - обработка данных на CPU
    
if __name__ == "__main__":

    with closing(asyncio.get_event_loop()) as event_loop:
        event_loop.run_until_complete(main())

Также посмотрите здесь: При как обстоятельствах закрывается потом в Python?

Comments

[Andrey Dugin]

Если понравился ответ - просьба отметить его решением.

Answer 2

[DarkMode]

import asyncio
import time

async def S():
    t = time.time()
    i = 0
    while time.time() - t < 1:
        i += 1
        loop.create_task(S())
    print("done")
loop = asyncio.get_event_loop()
cors = asyncio.wait([S()])
loop.run_until_complete(cors)