Java如何使用PriorityBlockingQueue类？
本示例演示如何使用PriorityBlockingQueue该类。该PriorityBlockingQueue是一个实现BlockingQueue接口。这是一个无限制的并发队列。此类队列中的对象位置必须实现java.lang.Comparable接口。该Comparable接口定义此队列内元素的顺序优先级。
为简单起见，在此示例中，我们使用字符串对象作为要放入队列中的元素。本String类实现可比的接口。当我们运行此示例时，它将按字母顺序打印出字符串数组中的名称。
package org.nhooo.example.util.concurrent;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.PriorityBlockingQueue;
public class PriorityBlockingQueueExample {
public static void main(String[] args) {
final String[] names =
{"carol", "alice", "malory", "bob", "alex", "jacobs"};
final BlockingQueue<String> queue = new PriorityBlockingQueue<>();
new Thread(new Runnable() {
@Override
public void run() {
for (int i = 0; i < names.length; i++) {
try {
queue.put(names[i]);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}, "Producer").start();
new Thread(new Runnable() {
@Override
public void run() {
try {
for (int i = 0; i < names.length; i++) {
System.out.println(queue.take());
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "Consumer").start();
}
}这段代码打印出来：
alex alice bob carol jacobs malory