simple producer consumer pattern impl

ProducerConsumerPatternTest.java

import org.junit.jupiter.api.Test;

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

/**
 * @author Hariom Yadav
 * @since 17-Nov-2023
 */
public class ProducerConsumerPatternTest {

    @Test
    public void foo() throws Exception{
        BlockingQueue<Integer> queue = new LinkedBlockingQueue<>(5);
        AtomicInteger atomic = new AtomicInteger(0);


        Runnable producer = () -> {
            while (true) {
                try {
                    Thread.sleep(1000);
                    queue.put(atomic.incrementAndGet());
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("Producer = " + queue);
            }
        };

        Runnable consumer = () -> {
            while (true) {
                try {
                    Thread.sleep(2000);
                    System.out.println("Consumer = " + queue.take());
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        };

        new Thread(producer).start();
        new Thread(consumer).start();
//        new Thread(consumer).start(); // ✅ we can create multiple producer and consumer and start all in parallel

        Thread.sleep(444444);
    }
}

producer consumer pattern using own blocking queue : https://gist.github.com/hocyadav/5447026432d5ecfd6ce44ee1a2abcdd4

other thread que: simple approach to print even and odd number using 2 thread : https://gist.github.com/hocyadav/5ad0a32002dc52820c9a13e4301ae67a