**********************************************************************
****************************消费者类*********************************
package test.com;
class Consumer extends Thread
{
Queue q;
Consumer(Queue q)
{
this.q=q;
}
public void run()
{
System.out.println("********Consumer****start*****");
while(true)
{
System.out.println("Consumer:"+q.get());
System.out.println("********Consumer****end*****");
}
}
}
