Java生产者和消费者例子_动力节点Java学院整理
生产者-消费者（producer-consumer）问题，也称作有界缓冲区（bounded-buffer）问题，两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者，用于将消息放入缓冲区；另外一个是消费者，用于从缓冲区中取出消息。问题出现在当缓冲区已经满了，而此时生产者还想向其中放入一个新的数据项的情形，其解决方法是让生产者此时进行休眠，等待消费者从缓冲区中取走了一个或者多个数据后再去唤醒它。同样地，当缓冲区已经空了，而消费者还想去取消息，此时也可以让消费者进行休眠，等待生产者放入一个或者多个数据时再唤醒它。
一，首先定义公共资源类，其中的变量number是保存的公共数据。
并且定义两个方法，增加number的值和减少number的值。由于多线程的原因，必须加上synchronized关键字，注意while判断的条件。
Java代码
二，分别定义生产
/**
*公共资源类
*/
publicclassPublicResource{
privateintnumber=0;
/**
*增加公共资源
*/
publicsynchronizedvoidincreace(){
while(number!=0){
try{
wait();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
number++;
System.out.println(number);
notify();
}
/**
*减少公共资源
*/
publicsynchronizedvoiddecreace(){
while(number==0){
try{
wait();
}catch(InterruptedExceptione){
e.printStackTrace();
}
}
number--;
System.out.println(number);
notify();
}
}
者线程和消费者线程，并模拟多次生产和消费，即增加和减少公共资源的number值
Java代码
/**
*生产者线程，负责生产公共资源
*/
publicclassProducerThreadimplementsRunnable{
privatePublicResourceresource;
publicProducerThread(PublicResourceresource){
this.resource=resource;
}
@Override
publicvoidrun(){
for(inti=0;i<10;i++){
try{
Thread.sleep((long)(Math.random()*1000));
}catch(InterruptedExceptione){
e.printStackTrace();
}
resource.increace();
}
}
}
/**
*消费者线程，负责消费公共资源
*/
publicclassConsumerThreadimplementsRunnable{
privatePublicResourceresource;
publicConsumerThread(PublicResourceresource){
this.resource=resource;
}
@Override
publicvoidrun(){
for(inti=0;i<10;i++){
try{
Thread.sleep((long)(Math.random()*1000));
}catch(InterruptedExceptione){
e.printStackTrace();
}
resource.decreace();
}
}
}
三，模拟多个生产者和消费者操作公共资源的情形，结果须保证是在允许的范围内。
Java代码
publicclassProducerConsumerTest{
publicstaticvoidmain(String[]args){
PublicResourceresource=newPublicResource();
newThread(newProducerThread(resource)).start();
newThread(newConsumerThread(resource)).start();
newThread(newProducerThread(resource)).start();
newThread(newConsumerThread(resource)).start();
newThread(newProducerThread(resource)).start();
newThread(newConsumerThread(resource)).start();
}
}
以上所述是小编给大家介绍的Java生产者和消费者例子，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！