diff --git a/get_data.py b/get_data.py index 481c816..094b67e 100644 --- a/get_data.py +++ b/get_data.py @@ -92,6 +92,25 @@ GAME_START_DT = None # datetime начала матча (локальная и GAME_TODAY = False # флаг: игра сегодня GAME_SOON = False # флаг: игра сегодня и скоро (<1 часа) +# общая очередь +results_q = queue.Queue() +# тут будем хранить последние данные +latest_data = {} +# событие для остановки потоков +stop_event = threading.Event() + +# отдельные события для разных наборов потоков +stop_event_live = threading.Event() +stop_event_offline = threading.Event() + +# чтобы из consumer можно было их гасить +threads_live = [] +threads_offline = [] + +# какой режим сейчас запущен: "live" / "offline" / None +CURRENT_THREADS_MODE = None + + URLS = { "seasons": "{host}/api/abc/comps/seasons?Tag={league}", "actual-standings": "{host}/api/abc/comps/actual-standings?tag={league}&season={season}&lang={lang}", @@ -107,7 +126,7 @@ URLS = { def start_offline_threads(season, game_id): """Запускаем редкие запросы, когда матча нет или он уже сыгран.""" - global threads_offline, CURRENT_THREADS_MODE, stop_event_offline + global threads_offline, CURRENT_THREADS_MODE, stop_event_offline, latest_data # если уже работаем в офлайне — не дублируем if CURRENT_THREADS_MODE == "offline": @@ -115,6 +134,8 @@ def start_offline_threads(season, game_id): # на всякий случай гасим лайв stop_live_threads() + + latest_data = None stop_event_offline.clear() threads_offline = [ @@ -257,23 +278,6 @@ def stop_offline_threads(): logger.info("[threads] OFFLINE threads stopped") -# общая очередь -results_q = queue.Queue() -# тут будем хранить последние данные -latest_data = {} -# событие для остановки потоков -stop_event = threading.Event() - -# отдельные события для разных наборов потоков -stop_event_live = threading.Event() -stop_event_offline = threading.Event() - -# чтобы из consumer можно было их гасить -threads_live = [] -threads_offline = [] - -# какой режим сейчас запущен: "live" / "offline" / None -CURRENT_THREADS_MODE = None # Функция запускаемая в потоках