}

////////////////////////////////////////// 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;
}

}