Day 3 Trivial use of BlockingQueue

SimonHGR · SimonHGR · commit 94a842642ee4 · 2021-09-10T16:13:34.000-06:00
diff --git a/src/main/java/prodcons/UseAQueue.java b/src/main/java/prodcons/UseAQueue.java
@@ -0,0 +1,34 @@
+package prodcons;
+
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.BlockingQueue;
+
+public class UseAQueue {
+  public static void main(String[] args) {
+    BlockingQueue<String> bqs = new ArrayBlockingQueue<>(10);
+    Runnable r = () -> {
+      System.out.println("worker starting");
+      int delay = 2000 + (int)(Math.random() * 2000);
+      try {
+        Thread.sleep(delay);
+        System.out.println("worker about to write message");
+        bqs.put("DIE!");
+        System.out.println("Message sent");
+      } catch (InterruptedException e) {
+        System.out.println("huh? who interrupted me!?");
+      }
+      System.out.println("worker finishing...");
+    };
+
+    System.out.println("main about to launch worker");
+    new Thread(r).start();
+    System.out.println("worker launched...");
+    try {
+      String msg = bqs.take();
+      System.out.println("main received message: " + msg);
+    } catch (InterruptedException e) {
+      System.out.println("Huh? main interrupted.");;
+    }
+    System.out.println("main exiting....");
+  }
+}
