Test.java

public class Test {

  private static List<String> messageQueue = new ArrayList<>();

  private static void put(String message) {
    synchronized (messageQueue) {
      messageQueue.add(message);
      messageQueue.notify();
    }
  }

  private static String get() throws InterruptedException {
    synchronized (messageQueue) {
      while (true) {
        if (!messageQueue.isEmpty()) {
          final String result = messageQueue.get(0);
          messageQueue.remove(0);
          return result;
        } else {
          messageQueue.wait();
        }
      }

    }
  }

  public static void main(String[] args) throws InterruptedException {
    final Thread thread = new Thread(() -> {
      while (true) {
        try {
          System.out.println(Thread.currentThread().getName() + " " + get());
        } catch (InterruptedException e) {
          System.out.println("Interrupted");
          return;
        }
      }
    });
    //thread.setDaemon(true);
    thread.start();
    for (int i = 0; i < 10; i++) {
      put("message" + i);
      Thread.sleep(1000);
    }
    thread.interrupt();
  }

}