core/simulator.py - master - Odisseywolf/BioSphere

core/simulator.py
112 строк5 KB
Odisseywolf
create: game.js, index.html, style.css, action-menu.js, ui-panel.js, hex-grid.js, water_systems.py, __init__.py, map_generator.py, ecosystem_engine.py, simulator.py, 8-terms-of-use.md, 4-about.md, 1-installation.md, 2-gameplay.md, 6-staff-guide.md, 10-license.md, 7-teacher-guide.md, 5-developer-guide.md, 9-user-agreements.md, 11-about-project.md, 3-rules.md
27 май 2026, 16:29
Верифицирован
27 май 2026, 16:29bd08518
# FILE: core/simulator.py
# AUTHOR: BioSphere Team
# LICENSE: GNU GPLv3
# DESCRIPTION: Основной цикл симуляции с масштабируемым временем

import time
import threading
from typing import Callable, Optional, List

class SimulationClock:
    """
    Управление игровым временем в BioSphere.
    
    Позволяет:
    - Запускать/останавливать симуляцию
    - Масштабировать время от 1 дня/мин до 100 лет/мин
    - Добавлять слушатели для реакции на каждый день
    - Автоматически ставить паузу при катастрофах
    """

    def __init__(self):
        self.is_running = False
        self.speed_factor = 1.0  # дней в секунду
        self.current_year = 0
        self.current_day = 0
        self.listeners: List[Callable[[int, int], None]] = []
        self.pause_listeners: List[Callable[[str], None]] = []
        self.catastrophe_callback = None
        self.thread: Optional[threading.Thread] = None
        self.last_tick = None

    def set_speed(self, years_per_minute: float):
        """
        Установить скорость симуляции.
        
        Аргументы:
            years_per_minute (float): сколько игровых лет проходит за минуту реального времени.
            Допустимые значения: от 0 (пауза) до 100.
            
        Примеры:
            0     → пауза
            1     → 1 день каждые ~60 секунд
            10    → 10 лет в минуту (~60 дней/сек)
            100   → 100 лет в минуту (~600 дней/сек)
        """
        if years_per_minute == 0:
            self.speed_factor = 0
        else:
            days_per_second = (years_per_minute * 365) / 60
            self.speed_factor = max(0.0167, min(days_per_second, 600))  # ограничение
        print(f"[CLOCK] Скорость установлена: {years_per_minute} лет/мин → {self.speed_factor:.2f} дней/сек")

    def add_listener(self, callback: Callable[[int, int], None]):
        """Добавить функцию, вызываемую каждый игровой день."""
        self.listeners.append(callback)

    def add_pause_listener(self, callback: Callable[[str], None]):
        """Добавить обработчик события паузы (например, для UI)."""
        self.pause_listeners.append(callback)

    def start(self):
        """Запустить симуляцию в фоновом потоке."""
        if not self.is_running:
            self.is_running = True
            self.last_tick = time.time()
            self.thread = threading.Thread(target=self._run, daemon=True)
            self.thread.start()
            print("[CLOCK] Симуляция запущена")

    def pause(self, reason: str = "manual"):
        """Остановить симуляцию."""
        self.is_running = False
        print(f"[CLOCK] Симуляция на паузе: {reason}")
        for listener in self.pause_listeners:
            try:
                listener(reason)
            except Exception as e:
                print(f"[ERROR] Ошибка в обработчике паузы: {e}")

    def _run(self):
        """Основной цикл симуляции (в отдельном потоке)."""
        while True:
            if not self.is_running:
                time.sleep(0.1)
                continue

            now = time.time()
            dt = now - self.last_tick
            self.last_tick = now

            steps = int(dt * self.speed_factor)
            for _ in range(steps):
                self.current_day += 1
                if self.current_day >= 365:
                    self.current_day = 0
                    self.current_year += 1

                # Вызов всех слушателей дня
                for listener in self.listeners:
                    try:
                        listener(self.current_year, self.current_day)
                    except Exception as e:
                        print(f"[ERROR] Ошибка в обработчике дня: {e}")

                # Проверка на экологическую катастрофу
                if self.catastrophe_callback:
                    crisis_type = self.catastrophe_callback()
                    if crisis_type:
                        self.pause(reason=f"catastrophe:{crisis_type}")
                        break

            time.sleep(0.01)  # предотвращаем перегрузку CPU