}
////////////////////////////////////////// InitQueue.java 初始化消费线程池
public class InitQueue {
private static QueueThread queue = null;
public InitQueue() {
synchronized (this) {
if (queue == null) {
System.out.println("初始化消费线程队列！启动5条");
queue = new QueueThread();
// 启动5条消费线程
for (int i = 0; i < 5; i++) {
Consumer c = new Consumer(queue);
c.start();
}
}
}
}
/**
* 获取
* @return
*/
public QueueThread getQueue() {
return queue;
}
}