Java¶àÏß³Ì: Éú²úÕßÏû·ÑÕßÎÊÌâ(Ô´Âë)

ÓÐÈË·´Ó³¿´²»µ½Ô´Â룬·¢ÏÖÊÇCSDNµÄ´úÂë¿Ø¼þÓÐÎÊÌ⡣ϣÍûCSDNºÃºÃ¸Ä½øһϡ£
ÔÝʱÏÈÒÔÎı¾·½Ê½·¢²¼³öÀ´£¬¸ñʽ»á±äÑù¡£
import java.util.LinkedList;
public class ProducerConsumer
{
 /**
  * @param args
  */
 public static void main(String[] args)
 {
  Queue queue = new Queue();
  
  Producer producer1 = new Producer(queue, "producer1");
  Producer producer2 = new Producer(queue, "producer2");
  
  Consumer consumer1 = new Consumer(queue, "consumer1");
  Consumer consumer2 = new Consumer(queue, "consumer2");
  Consumer consumer3 = new Consumer(queue, "consumer3");
  
  producer1.start();
  producer2.start();
  consumer1.start();
  consumer2.start();
  consumer3.start();
 }
}
class Message
{
 public static int sno = 0;
 
 public int id = 0;
 
 public String content = null;
 
 public Message(String content)
 {
  synchronized(Message.class)
  {
   this.id = ++sno;
  }  
  this.content = content;
 }
 public String toString()
 {
  return "id = " + id + ", content = " + content;
 }
}
class Queue
{
 private LinkedList queue = null;
 private int capacity = 0;
 
 public Queue(int capacity)
 {
  this.capacity = capacity;
  queue = new LinkedList();
 }
 public Queue()
 {
  this(10);
 }
 
 public synchronized void put(Message product)
 {
  //wait until the consumer has consume a product
  while(queue.size() >= capacity)
  {
   try
   {
    wait();
   }
   catch (InterruptedException e)
   {
  &