Java如何使用BlockingQueue对象？
Ajava.util.concurrent.BlockingQueue是扩展的接口，java.util.Queue为阻塞操作添加了特殊支持。当检索元素操作发生时，它将等待或阻止队列变为可用，并等待或阻止存储元素操作，直到队列具有可用空间为止。
该java.util.concurrent.BlockingQueue接口有一些可用的实现。这些实现包括以下类：
java.util.concurrent.ArrayBlockingQueue
java.util.concurrent.DelayQueue
java.util.concurrent.LinkedBlockingDeque
java.util.concurrent.LinkedBlockingQueue
java.util.concurrent.PriorityBlockingQueue
java.util.concurrent.SynchronousQueue
下面是如何使用BlockingQueue的示例。在本例中，我们使用接口的ArrayBlockingQueue实现。这个例子然后为每个生产者和消费者对象创建不同的线程。这两个线程都使用共享阻塞队列，其中生产者对象存储一些元素，消费者对象尝试检索这些元素。
package org.nhooo.example.util.concurrent;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class BlockingQueueExample {
public static void main(String[] args) {
BlockingQueue<String> queue = new ArrayBlockingQueue<>(32);
Producer producer = new Producer(queue);
Consumer consumer = new Consumer(queue);
new Thread(producer, "Producer").start();
new Thread(consumer, "Consumer").start();
}
}这是Producer类。我们定义一个字符串数组，并使用 for-loop迭代该数组以将元素存储到队列中。我们通过调用BlockingQueue的put ()方法来实现这一点。如果队列中没有可用空间，则put()方法阻塞进程。在这里调用Thread.sleep()方法会导致 Consumer在等待队列中可用的对象时阻塞。
package org.nhooo.example.util.concurrent;
import java.util.concurrent.BlockingQueue;
public class Producer implements Runnable {
BlockingQueue<String> queue;
Producer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
System.out.println("Producer.run");
String[] data = {"D001", "D002", "D003", "D004", "D005"};
try {
for (String element : data) {
queue.put(element);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}Consumer对象循环从队列中检索元素。在此示例中，我们使用BlockingQueue的take()方法检索元素并将其打印到控制台中。
package org.nhooo.example.util.concurrent;
import java.util.concurrent.BlockingQueue;
public class Consumer implements Runnable {
BlockingQueue<String> queue;
Consumer(BlockingQueue<String> queue) {
this.queue = queue;
}
@Override
public void run() {
System.out.println("Consumer.run");
while (true) {
System.out.println("Reading queue...");
try {
System.out.println(queue.take());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}在BlockingQueue具有用于在队列中的存储和检索的元素设置四种不同的方法。每种方法都有不同的行为。