Java线程间同步实现生产者-消费者模式

Java线程间同步实现生产者-消费者模式生产者与消费者模式是我们在编程过程中常常会遇到的，就像我们生活那样，生产者生产出产品，消费者去购置产品。在这里我们创立三个线程，一个主控线程main，用于创立各帮助线程；一个生产者线程，用于生产产品；一个消费者线程，用于购置产品。另外，我们创立一个队列类Queue，生产线程生产的产品将放置到该队列中，然后消费者线程在该队列中取走产品。

2.实现该模式的要点:

首先必需让生产者线程与消费者线程到达同步，也就是说，当生产者线程生产出产品后，消费者才能去取，依此轮回。当生产者线程放置产品到队列中时，队列要检查队列是否已满，如已满，则等待消费者线程将产品取走，否则放置产品到队列中。当消费者线程在队列中取产品时，队列也要检查队列是否为空，假如为空，则等待生产者线程放置产品到队列，否则在队列中取走产品。

3.源代码:

classMainThread

{

publicstaticvoidmain(String[]args)

{

Queuequeue=newQueue();

Producerproducer=newProducer(queue);

Consumerconsumer=newConsumer(queue);

newThread(producer).start();

newThread(consumer).start();

}

}

/*留意:waitnotifynotifyAll只能在同步方法或内步块中调用*/

classQueue

{

intproduct=0;

booleanbfull=false;

publicsynchronizedvoidsetProduct(intproduct)

{

if(bfull)//假如队列已满,则调用wait等待消费者取走产品

{

try

{

wait();

}

catch(Exceptione)

{

e.printStackTrace();

}

}

/*开头放置产品到队列中*/

duct=product;

System.out.println(“Producersetproduct:“+product);

bfull=true;

notify();//生产产品后通知消费者取走产品

}

publicsynchronizedvoidgetProduct()

{

if(!bfull)//假如队列是空的,则调用wait等待生产者生产产品

{

try

{

wait();

}

catch(Exceptione)

{

e.printStackTrace();

}

}

/*开头从队列取走产品*/

System.out.println(“Consumergetproduct:“+product);

bfull=false;

notify();//取走产品后通知生产者连续生产产品

}

}

classProducerimplementsRunnable

{

Queuequeue;

Producer(Queuequeue)

{

this.queue=queue;

}

publicvoidrun()//生产线程

{

for(inti=1;i<=10;i++)

{

queue.setProduct(i);

}

}

}

classConsumerimplementsRunnable

{

Queuequeue;

Consumer(Queuequeue)

{

this.queue=queue;

}

publicvoidrun()//消费线程

{

for(inti=1;i<=10;i++)

{

queue.getProduct();

}

}

}

输出结果如下:

Producersetproduct:1

Consumergetproduct:1

Producersetproduct:2

Consumergetproduct:2

Producersetproduct:3

Consumergetproduct:3

Producersetproduct:4

Consumergetproduct:4

Producersetproduct:5

Consumergetproduct:5

Producersetproduct:6

Consumergetproduct:6

Producersetproduct:7

Consumergetproduct:7

Producersetproduct:8

Consumer