LeakyBucket.java

import java.util.Scanner;

public class LeakyBucket {
    public static void main(String[] args) throws InterruptedException {
        Scanner sc = new Scanner(System.in);
        
        System.out.print("Enter bucket size: ");
        final int size = sc.nextInt();
        System.out.print("Enter output rate: ");
        final int outRate = sc.nextInt();
        System.out.print("Enter input size: ");
        final int n = sc.nextInt();
        System.out.print("Enter input rate: ");
        final int inRate = sc.nextInt();
        
        int buffer = 0;
        while (n != 0) {
            System.out.println("\nIncoming rate: " + inRate);
            if (inRate <= size - buffer) {
                buffer += inRate;
            } else {
                System.out.println("Packet lost: " + inRate - (size - buffer));
                buffer = size;
            }
            System.out.println("Bucket buffer has " + buffer + " out of " + size);
            
            buffer -= outRate;
            System.out.println("After outgoing, buffer has " + buffer + " out of " + size);
            n--;
            Thread.sleep(1000);
        }
        
        sc.close();
    }
}