Java函数的并发和多线程中如何实现生产者和消费者模型？

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.function.Supplier;

public class ProducerConsumer {

  private static BlockingQueue<Integer> queue = new LinkedBlockingQueue<>();

  public static void main(String[] args) {
    Supplier<Integer> producer = () -> {
      while (true) {
        try {
          // 留存一个元艳
          int element = produce();

          // 将元艳搁进行列步队
          queue.put(element);

          // 稍做苏息，如故生存工夫
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    };

    Consumer<Integer> consumer = (element) -> {
      while (true) {
        try {
          // 从行列步队外掏出元艳
          element = queue.take();

          // 生涯元艳
          consume(element);

          // 稍做苏息，模仿出产光阴
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    };

    // 创立一个保管者线程
    Thread producerThread = new Thread(producer);

    // 创立二个生存者线程
    Thread consumerThread1 = new Thread(consumer);
    Thread consumerThread二 = new Thread(consumer);

    // 封动线程
    producerThread.start();
    consumerThread1.start();
    consumerThread两.start();
  }

  // 仍旧生存元艳的法子
  private static int produce() {
    return (int) (Math.random() * 100);
  }

  // 如故出产元艳的办法
  private static void consume(int element) {
    System.out.println("Consumed element: " + element);
  }
}

$ javac ProducerConsumer.java
$ java ProducerConsumer

Consumed element: 两3
Consumed element: 7两
Consumed element: 15
Consumed element: 44
Consumed element: 87
...