SimulationController.java

//The siulation control

import java.util.*;

public class SimulationController {
//Kamva
    private final CampusRoute campusRoute;
    private final Random random = new Random();
    private Thread passengerSpawner;
    private volatile boolean running = false;

    public SimulationController(int numStops, int numBuses) {
    
        this.campusRoute = new CampusRoute(numStops);

        for (int i = 0; i < numBuses; i++) {
            Bus bus = new Bus(i + 1, campusRoute);
            campusRoute.addBus(bus);
        }
    }

    public CampusRoute getCampusRoute() {
        return campusRoute;
    }

    public void startSimulation() {
        if (running) return;
        running = true;

        // Start buses
        for (Bus bus : campusRoute.getBuses()) {
            new Thread(bus).start();
        }

    // spawn passenger in a separate thread
    passengerSpawner = new Thread(() -> {
    Random rand = new Random();

    while (running) {
        int numStops = campusRoute.getNumberOfStops();

        
        int start = rand.nextInt(numStops);
        int destination = (start + 1 + rand.nextInt(numStops - 1)) % numStops;

        Passenger passenger = new Passenger(start, destination);
        campusRoute.getStop(start).addPassenger(passenger);
        
        Bus randomBus = campusRoute.getBuses().get(rand.nextInt(campusRoute.getBuses().size()));
        randomBus.addPassenger(passenger);

        // weit before spawning the next passenger
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            break;
        }
    }
});

        passengerSpawner.start();
    }

    public void stopSimulation() {
        running = false;
        if (passengerSpawner != null) {
            passengerSpawner.interrupt();
        }
        System.out.println("Simulation stopped.");
    }
}