Почему данный код является рабочим?

Question

[Ёшинон Ушастый]

Всем доброго времени суток!
Имеется такой код:

while (1):
    for iterator in range(len(posts)):
        # Для прозрачности вычислений
        time_post_a = datetime.now()
        time_post_a = int(time.mktime(time_post_a.timetuple()))

        time_post_b = posts[iterator]['time']
        time_post_b = int(time.mktime(time_post_b.timetuple()))

        # Выполнить действие, в случае, если "время пришло" по массиву posts
        if ((time_post_a - time_post_b) == 0):
            print ('Итератор: ' + str(iterator) + ', Новая публикация: ' + str(posts[iterator]['time']))
            time.sleep(1) # Если его убрать, то начинаются дикие пляски
            break

Он работает(!!!). Но не кажется достаточно прозрачным... например, в голову не приходит здравой идеи о том, как выводит отсчёт вплоть до секунд, до наступления событий. Так же он не может вывести список того, что уже просрочено по времени.
В общем, код явного пахнет костылём... интересно, каким образом можно сделать его лучше?
Основная задача - вызов условия по времени, которое заранее задано

Comments

[res2001]

Где добавляются и удаляются записи в post?
Если бы вы при добавлении взводили таймер на указанное время, то можно было бы вообще уйти от вечного цикла и работать по событиям. И весь этот код стал бы не нужным, кроме строки с print.

Answer 1

[Andrey Dugin]

Если бы был конкурс на написание самого кривого планировщика событий (task scheduler) - этот код, несомненно, занял бы первое место) Попробуйте, например, delayed calls в asyncio.

UPD Пример простого решения "в лоб", без асинхронности:

from time import time, sleep
from operator import attrgetter

class Article:

    def __init__(self, timestamp, text):
        self.timestamp, self.text = timestamp, text

    def post(self):
        print(f"planned={self.timestamp:.0f}, posted={time():.0f}, text={self.text}")

class Scheduler:
    
    def __init__(self, *articles):
        self.articles = sorted(articles, key=attrgetter("timestamp"))

    def execute(self):
        for article in self.articles:
            sleep(max(article.timestamp - time(), 0))
            article.post()

if __name__ == "__main__":

    now = time()

    Scheduler(
        Article(now + 7, "post3"),
        Article(now + 2, "post1"),
        Article(now + 3, "post2"),
    ).execute()

Comments

[Ёшинон Ушастый]

Полностью согласен с Вами :D
Дело в том, что этот код получился совершенно спонтанно и я не могу понять, каким образом он работает

[Andrey Dugin]

Aquinary, а он и не работает. Например, условие, когда дельта времени равна нулю, может никогда не быть выполнено. И ещё куча косяков. С алгоритмом сама по себе беда: зачем делать sleep(1), если логично делать sleep на минимальный интервал времени до следующего поста (или группы постов, если у них одинаковое запланированное время). Кроме того, этот sleep является блокирующим. Вероятно, стоит использовать asyncio.sleep(). И т.д. и т.п. Правильное решение - один раз пробежаться по всему циклу и для каждого поста зарядить таски через asyncio.call_later(). Тогда всё само выполнится в нужное время.

[Ёшинон Ушастый]

Андрей Дугин,

def event_handler(loop, array, iterator):
    print ('Итератор: ' + str(iterator) + ', Тип: '+ str(array[iterator]['type']) +', Время публикации: ' + str(array[iterator]['time']))
if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    try:
        print('Цикл событий запускается')
        for iterator in range(len(posts)):
            time_post_a = datetime.today()
            time_post_a = int(time.mktime(time_post_a.timetuple()))

            time_post_b = posts[iterator]['time']
            time_post_b = int(time.mktime(time_post_b.timetuple()))
            
            if (time_post_b > time_post_a):
                time_post = time_post_b - time_post_a
                loop.call_later(time_post, event_handler, loop, posts, iterator)
        loop.run_forever()
    finally:
        print('Завершаю цикл событий')
        loop.close()

Как-то так. Верно ли? Или можно ещё лучше?

[Andrey Dugin]

Нет, неправильно:
1) Зачем снова используете тот же самый плохой код?
2) Из loop.run_forever() нужно выходить через loop.stop() - где это реализовано?
3) Не следует называть итератором то, что итератором не является.

Answer 2

[Stalker_RED]

1. вычисляем оставшееся время для всех постов
2. находим минимальное
3. time.sleep( то что вычислили в п. 2 )
4. print ...
5. вернуться к п. 1

Так же он не может вывести список того, что уже просрочено

Что вы вообще хотите сделать?

Вопрос из заголовка совсем странный. Работает он потому, что может. Синтаксических ошибок нет, по логике тоже все ок, а на плохой стиль компилятор не ругается. Возможно линтер какой-нибудь ругнется, но его же специально об этом попросить нужно.