Create producer_consumer.java

IntScription · IntScription · commit 96ae339351e4 · 2023-08-05T16:47:38.000+05:30
diff --git a/Producer_Consumer/producer_consumer.java b/Producer_Consumer/producer_consumer.java
@@ -0,0 +1,78 @@
+/*
+ * Write a java program that corrects implements of producer consumer problem.
+ */
+
+
+package Producer_Consumer;
+
+class Q {
+	int n;
+	boolean valueSet = false;
+
+	synchronized int get() {
+		if (!valueSet)
+			try {
+				wait();
+			} catch (InterruptedException e) {
+				System.out.println("Interrupted Exception caught");
+			}
+		System.out.println("Got:" + n);
+		valueSet = false;
+		notify();
+		return n;
+	}
+
+	synchronized void put(int n) {
+		if (valueSet)
+			try {
+				wait();
+			} catch (InterruptedException e) {
+				System.out.println("Interrupted Exception caught");
+			}
+		this.n = n;
+		valueSet = true;
+		System.out.println("Put:" + n);
+		notify();
+	}
+}
+
+
+class Producer implements Runnable {
+	Q q;
+
+	Producer(Q q) {
+		this.q = q;
+		new Thread(this, "Producer").start();
+	}
+
+	public void run() {
+		int i = 0;
+		while (true) {
+			q.put(i++);
+		}
+	}
+}
+
+
+class Consumer implements Runnable {
+	Q q;
+
+	Consumer(Q q) {
+		this.q = q;
+		new Thread(this, "Consumer").start();
+	}
+
+	public void run() {
+		while (true) {
+			q.get();
+		}
+	}
+}
+
+public class producer_consumer {
+    public static void main(String[] args){
+        Q q = new Q();
+		new Producer(q);
+		new Consumer(q);
+    }
+}
