Выполнить другую функцию если первая выполняется дольше 15 секунд?

Question

[estry]

Есть асинхронные функции get_count, get_result и notification.
Функция get_count вызывается из функции get_result. Однако выполнение функции get_count может занять длительное время.
Как сделать так, чтобы при выполнение функции get_count дольше 15 секунд вызывалась функция notification? Но при этом выполнение функции get_count не должно прерываться.

Comments

[Влад Григорьев]

для начала надо понимать за счет чего тормозит get_count, и уже от этого плясать
так что скидывай код, что б могли давать релевантные совытия.

По скорее всего придется просто использовать многопроцессорность и какие-нибудь сигналы

[Даниил Рыжов]

Предлагаю почитать Asyncio Executing code in thread or process pools

Answer 1

[Vindicar]

Тривиально. Что-то вроде

async def notify_long_task():
    'Выполняет оповещение о длинной операции.'
    await asyncio.sleep(15.0)  # ждём таймаут
    await send_notification('Извините, я что-то туплю.')  # оповещаем

async def actual_long_task():
    notification = asyncio.create_task(notify_long_task())  # планируем оповестить
    await perform_long_task()  # потенциально долгая операция
    notification.cancel()  # отменяем оповещение, если оно ещё не сработало.