Bus.java

//The Bus code
//This is were the action is  going to be happenning

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

public class Bus implements Runnable {
//Kamva
    private final int busId;
    private final CampusRoute route;
    private final BlockingQueue<Passenger> passengerQueue;
    private Passenger currentPassenger;

    private int currentX;
    private int currentY;

    public Bus(int busId, CampusRoute route) {
    
        this.busId = busId;
        this.route = route;
        this.passengerQueue = new LinkedBlockingQueue<>();

        // for uniform the buses should start at Stop 0
        int[] coords = route.getStopCoordinates(0);
        this.currentX = coords[0];
        this.currentY = coords[1];
    }

    @Override
    public void run() {
        while (true) {
            try {
            
                currentPassenger = passengerQueue.take();
                pickUpPassenger(currentPassenger);
                driveToDestination(currentPassenger);
                currentPassenger = null;
                
            } 
            catch (InterruptedException e) {
            
                Thread.currentThread().interrupt();
                break;
            }
        }
    }

    public void pickUpPassenger(Passenger passenger) {
    
        System.out.println("Bus " + busId + " picked up passenger at Stop " + passenger.getStartingStop());
        
    }

    public void driveToDestination(Passenger passenger) {
    
        int stopIndex = passenger.getDestinationStop();
        int[] coords = route.getStopCoordinates(stopIndex);

        moveTowards(coords[0], coords[1]);
        System.out.println("Bus " + busId + " dropped passenger at Stop " + stopIndex);
    }

    private void moveTowards(int destX, int destY) {
        while (currentX != destX || currentY != destY) {
        
            if (currentX < destX) currentX++;
            else if (currentX > destX) currentX--;

            if (currentY < destY) currentY++;
            else if (currentY > destY) currentY--;

            try {
                Thread.sleep(10); 
            } 
            catch (InterruptedException e) {
            
                Thread.currentThread().interrupt();
                break;
            }
        }
    }

    public void addPassenger(Passenger passenger) {
        passengerQueue.offer(passenger);
    }

    public int getCurrentX() {
        return currentX;
    }

    public int getCurrentY() {
        return currentY;
    }

    public int getBusId() {
        return busId;
    }
}