javalab20.java

import java.util.*;

class ProducerConsumer extends Thread{
    LinkedList<Integer> buffer =  new LinkedList<>();
    Scanner sc = new Scanner(System.in);
    int capacity=5;
    int value=1;
    public synchronized void produce() {
        try {
            if (buffer.size() == capacity) {
                System.out.println("Buffer full. Producer is waiting...");
                wait(); // Producer waits if buffer full
            }

            for (int i = 0; i < capacity; i++) {
                System.out.println("Producer produced: " + value);
                buffer.add(value++); 
                Thread.sleep(500);
            }
    
            System.out.println();

            notify(); // Wake up consumer
            
            Thread.sleep(1000);

        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public synchronized void consume() {
        try {
            if (buffer.size() == 0) {
                System.out.println("Buffer empty. Consumer is waiting...");
                wait(); // Consumer waits if buffer empty
            }

        for(int i=0; i< capacity; i++){
                int value = buffer.removeFirst();
                System.out.println("Consumer consumed: " + value);
                Thread.sleep(500);
        }

            notify(); // Wake up producer

            Thread.sleep(1000);

        } catch (InterruptedException e) {
            e.printStackTrace();
            /*.printStackTrace() is a method that prints the full error details to your console.

            It shows where the exception happened, including:
            the exact line number,
            class name,
            method call hierarchy.*/
        }
    }
}

public class javalab20 {
    public static void main(String [] args) {

        ProducerConsumer ob =  new ProducerConsumer();
        Scanner sc = new Scanner(System.in);
        System.out.print("Enter how many times you want to do the process: ");
        int n = sc.nextInt();
        for (int i = 0; i < n; i++) {
            System.out.println();
            System.out.println();
            System.out.println("Process " + (i + 1));
            System.out.println();
            ob.produce();
            ob.consume();
            try {
                Thread.sleep(1000); // Sleep after each cycle
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        sc.close();
    }
}