}

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

}