rfcosta
diff --git a/Collapse file
‎JavaMultiThreadingCodes/src/ProducerConsumer_7/App.java‎
Copy file name to clipboardExpand all lines: JavaMultiThreadingCodes/src/ProducerConsumer_7/App.java
+10-13Lines changed: 10 additions & 13 deletions b/Collapse file
‎JavaMultiThreadingCodes/src/ProducerConsumer_7/App.java‎
Copy file name to clipboardExpand all lines: JavaMultiThreadingCodes/src/ProducerConsumer_7/App.java
+10-13Lines changed: 10 additions & 13 deletions
@@ -32,33 +32,30 @@ public class App {
     private static BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
 
     public static void main(String[] args) throws InterruptedException {
-        /**
-         *
-         */
+
         Thread t1 = new Thread(new Runnable() {
             public void run() {
                 try {
                     producer();
-                } catch (InterruptedException e) {
-                    e.printStackTrace();
-                }
+                } catch (InterruptedException ignored) {}
             }
         });
 
         Thread t2 = new Thread(new Runnable() {
             public void run() {
                 try {
                     consumer();
-                } catch (InterruptedException e) {
-                    // TODO Auto-generated catch block
-                    e.printStackTrace();
-                }
+                } catch (InterruptedException ignored) {}
             }
         });
         t1.start();
         t2.start();
-        t1.join();
-        t2.join();
+//        t1.join();
+//        t2.join();
+
+        // Pause for 30 seconds and force quitting the app (because we're looping infinitely)
+        Thread.sleep(30000);
+        System.exit(0);
     }
 
     private static void producer() throws InterruptedException {
@@ -71,7 +68,7 @@ private static void producer() throws InterruptedException {
     private static void consumer() throws InterruptedException {
         Random random = new Random();
         while (true) {
-            //Thread.sleep(100);
+            Thread.sleep(100);
             if (random.nextInt(10) == 0) {
                 Integer value = queue.take();//if queue is empty waits
                 System.out.println("Taken value: " + value + "; Queue size is: " + queue.size());