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....");
  }
}