src/bin/run_large_scale.rs

// 🚀 100만 노드 대규모 병렬 + 실시간 파동 주입 통합 벤치마크 (src/bin/run_large_scale.rs)
#[path="../live_streamer.rs"] mod live_streamer;
#[path="../parallel_engine.rs"] mod parallel_engine;
#[path="../korean_telemetry.rs"] mod korean_telemetry;

use std::time::Instant;
use live_streamer::LiveSignalStreamer;
use parallel_engine::LargeScaleEngine;
use korean_telemetry::TelemetryReporter;

fn main() {
    println!("============================================================");
    println!(" 🚀 BioPhys 100만 노드(1024x1024) 대규모 병렬 엔진 구동");
    println!("============================================================\n");

    let grid_size = 1024; // 1,048,576 노드
    let total_nodes = grid_size * grid_size;
    println!("⚙️ [시스템 사양] 총 {}개 8대 위상 노드 할당 완료 (1M Nodes)", total_nodes);

    let mut engine = LargeScaleEngine::new(grid_size);
    let mut streamer = LiveSignalStreamer::new(3.0); // 3Hz 고조파 파동

    println!("🌊 [실시간 신호] 고주파 외부 파동(Harmonic Wave) 실시간 주입 시작...\n");

    let total_ticks = 10;
    let start_time = Instant::now();

    for tick in 1..=total_ticks {
        // 1. 외부 실시간 파동 신호 생성 및 암반층 주입
        let external_wave = streamer.generate_harmonic_wave(grid_size);
        for (b, w) in engine.bedrock.iter_mut().zip(external_wave.iter()) {
            *b = (*b * 0.7) + (*w * 0.3); // 외부 파동 융합
        }

        // 2. 100만 노드 멀티스레드 병렬 계산 (Rayon)
        let tick_start = Instant::now();
        let avg_energy = engine.step_parallel();
        let tick_dur = tick_start.elapsed();

        // 3. 한국어 텔레메트리 보고
        let sample_phases: Vec<f32> = engine.topsoil[0..10_000].iter().map(|p| p.value()).collect();
        let report = TelemetryReporter::analyze(&sample_phases, avg_energy, tick);
        print!("{}", report);
        println!("   └─ 100만 노드 1-Tick 소요 시간: {:.2} ms\n", tick_dur.as_secs_f64() * 1000.0);
    }

    let total_elapsed = start_time.elapsed().as_secs_f64();
    let total_cell_updates = (total_nodes as f64) * (total_ticks as f64);
    let mega_updates_per_sec = (total_cell_updates / total_elapsed) / 1_000_000.0;

    println!("============================================================");
    println!(" 📊 대규모 병렬 실측 벤치마크 결과");
    println!("============================================================");
    println!(" ⏱️ 총 연산 시간         : {:.4} 초", total_elapsed);
    println!(" 🔄 총 갱신 셀 수        : {:.1} Million Cells", total_cell_updates / 1_000_000.0);
    println!(" ⚡ 멀티스레드 처리량     : {:.2} MCell/sec (초당 수억 개 셀)", mega_updates_per_sec);
    println!("============================================================");
}