ychernenko/RFB
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

чистим lates_data перед запуском оффлайн треда

Browse Source
This commit is contained in:
Юрий Черненко
2025-11-01 12:53:17 +03:00
parent 698674b319
commit 3821a1b2a6
1 changed files with 22 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
get_data.py
View File

@@ -92,6 +92,25 @@ GAME_START_DT = None # datetime начала матча (локальная и
GAME_TODAY = False # флаг: игра сегодня GAME_TODAY = False # флаг: игра сегодня
GAME_SOON = False # флаг: игра сегодня и скоро (<1 часа) 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 = { URLS = {
"seasons": "{host}/api/abc/comps/seasons?Tag={league}", "seasons": "{host}/api/abc/comps/seasons?Tag={league}",
"actual-standings": "{host}/api/abc/comps/actual-standings?tag={league}&season={season}&lang={lang}", "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): 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": if CURRENT_THREADS_MODE == "offline":
@@ -116,6 +135,8 @@ def start_offline_threads(season, game_id):
# на всякий случай гасим лайв # на всякий случай гасим лайв
stop_live_threads() stop_live_threads()
latest_data = None
stop_event_offline.clear() stop_event_offline.clear()
threads_offline = [ threads_offline = [
threading.Thread( threading.Thread(
@@ -257,23 +278,6 @@ def stop_offline_threads():
logger.info("[threads] OFFLINE threads stopped") 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
# Функция запускаемая в потоках # Функция запускаемая в потоках