Hero - Multithreading - Consumer Producer problem

src/com/hero/multithreading/producerconsumer/Message.java

@@ -0,0 +1,19 @@
+package com.hero.multithreading.producerconsumer;
+
+public class Message {
+
+    private String message;
+
+    public Message(String message) {
+        this.message = message;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+}

src/com/hero/multithreading/producerconsumer/MessageConsumer.java

@@ -0,0 +1,28 @@
+package com.hero.multithreading.producerconsumer;
+
+import java.util.concurrent.BlockingQueue;
+
+public class MessageConsumer implements Runnable {
+
+    private BlockingQueue<Message> queue;
+
+    public MessageConsumer(BlockingQueue<Message> queue) {
+        this.queue = queue;
+    }
+
+    @Override
+    public void run() {
+        try {
+            Message message;
+            while (!"exit".equals((message = queue.take()).getMessage())) {
+                Thread.sleep(100);
+                System.out.println("Message is consumed: " + message.getMessage());
+            }
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+
+
+
+    }
+}

src/com/hero/multithreading/producerconsumer/MessageProducer.java

@@ -0,0 +1,31 @@
+package com.hero.multithreading.producerconsumer;
+
+import java.util.concurrent.BlockingQueue;
+
+public class MessageProducer implements Runnable {
+
+    private BlockingQueue<Message> queue;
+
+    public MessageProducer(BlockingQueue<Message> queue) {
+        this.queue = queue;
+    }
+
+    @Override
+    public void run() {
+        for (int i = 0; i < 100; i++) {
+            Message message = new Message("" + i);
+            try {
+                queue.put(message);
+                System.out.println("Message added to queue: " + message.getMessage());
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
+        }
+        try {
+            queue.put(new Message("exit"));
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+}

src/com/hero/multithreading/producerconsumer/ProducerConsumerApp.java

@@ -0,0 +1,17 @@
+package com.hero.multithreading.producerconsumer;
+
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.BlockingQueue;
+
+public class ProducerConsumerApp {
+
+    public static void main(String[] args) {
+        BlockingQueue<Message> queue = new ArrayBlockingQueue<>(5);
+        MessageProducer producer = new MessageProducer(queue);
+        MessageConsumer consumer = new MessageConsumer(queue);
+
+        new Thread(producer).start();
+        new Thread(consumer).start();
+
+    }
+}