ArrayBlockingQueue

import java.util.concurrent.ArrayBlockingQueue;

public class Producer implements Runnable {
    
    private ArrayBlockingQueue<String> queue;
    private String producerName;
    
    public Producer(String producerName, ArrayBlockingQueue<String> queue) {
        this.queue = queue;        
        this.producerName = producerName;
    }

    @Override
    public void run() {
        while(true){
            try {
                this.queue.put("Produced by " + this.producerName);
                System.out.println("Number of products in the queue after production: " + this.queue.size());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

import java.util.concurrent.ArrayBlockingQueue;

public class Consumer implements Runnable {
    
    private ArrayBlockingQueue<String> queue;
    
    public Consumer(ArrayBlockingQueue<String> queue) {
        this.queue = queue;            
    }

    @Override
    public void run() {
        while(true){
            try {
                this.queue.take();
                System.out.println("Number of products in the queue after consumption: " + this.queue.size());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

}

import java.util.concurrent.ArrayBlockingQueue;

public class ProducerConsumerTest {

    public static void main(String[] args) {
        
        ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<String>(10);
        
        Producer producer1 = new Producer("producer1", queue);
        Producer producer2 = new Producer("producer2", queue);
        Producer producer3 = new Producer("producer2", queue);
        
        Consumer consumer1 = new Consumer(queue);
        Consumer consumer2 = new Consumer(queue);
        Consumer consumer3 = new Consumer(queue);
        
        new Thread(producer1).start();
        new Thread(producer2).start();
        new Thread(producer3).start();
        new Thread(consumer1).start();
        new Thread(consumer2).start();
        new Thread(consumer3).start();            
    }
}