Java

Producer-Consumer

package com.concurrency;

import java.util.concurrent.ConcurrentLinkedQueue;

public class ITCExist {

	private static ConcurrentLinkedQueue<Integer> clQ = new ConcurrentLinkedQueue<>();

	static class Producer implements Runnable {
		@Override
		public void run() {
			int i = 0;
			while (true) {
				clQ.add(i);
				System.out.println("produced i"+i++);
				synchronized (clQ) {
					clQ.notify();
				}
				try {
					Thread.sleep(1);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		}
	}

	static class Consumer implements Runnable {
		@Override
		public void run() {
			while (true) {
				synchronized (clQ) {
					if (clQ.isEmpty())
						try {
							clQ.wait();
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					int i = clQ.poll();
					System.out.println("consumed i "+i);
				}
			}
		}
	}

	public static void main(String[] args) throws InterruptedException{
		Thread prod = new Thread(new Producer(), "prod");
		Thread cons = new Thread(new Consumer(), "cons");
		cons.start();
		prod.start();
		cons.join();
		prod.join();
		System.out.println("Completed!");

	}
}