ConcurrentLinkedQueue Example in Java

ConcurrentLinkedQueueExample.java

import java.util.concurrent.ConcurrentLinkedQueue;

public class Queues {

  private static final ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<>();
  private static boolean running = true;

  public static void main(String[] args) throws InterruptedException {
    new Thread(Queues::produce).start();
    new Thread(Queues::consume).start();

    Thread.sleep(100);
    running = false;
  }

  private static void produce() {
    for (int i = 0; running; i++) {
      queue.offer(i);
    }
  }

  private static void consume() {
    while (running) {
      System.out.println("Received: " + queue.poll());
    }
  }
}