欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java生产者和消费者例子_动力节点Java学院整理

程序员文章站 2024-02-13 15:21:28
生产者-消费者(producer-consumer)问题,也称作有界缓冲区(bounded-buffer)问题,两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者,用...

生产者-消费者(producer-consumer)问题,也称作有界缓冲区(bounded-buffer)问题,两个进程共享一个公共的固定大小的缓冲区。其中一个是生产者,用于将消息放入缓冲区;另外一个是消费者,用于从缓冲区中取出消息。问题出现在当缓冲区已经满了,而此时生产者还想向其中放入一个新的数据项的情形,其解决方法是让生产者此时进行休眠,等待消费者从缓冲区中取走了一个或者多个数据后再去唤醒它。同样地,当缓冲区已经空了,而消费者还想去取消息,此时也可以让消费者进行休眠,等待生产者放入一个或者多个数据时再唤醒它。

一,首先定义公共资源类,其中的变量number是保存的公共数据。

并且定义两个方法,增加number的值和减少number的值。由于多线程的原因,必须加上synchronized关键字,注意while判断的条件。

java代码  

二,分别定义生产

 /** 
 * 公共资源类 
 */ 
 public class publicresource { 
   private int number = 0; 
  
   /** 
   * 增加公共资源 
   */ 
   public synchronized void increace() { 
     while (number != 0) { 
       try { 
         wait(); 
       } catch (interruptedexception e) { 
         e.printstacktrace(); 
       } 
     } 
     number++; 
     system.out.println(number); 
     notify(); 
   } 
  
   /** 
   * 减少公共资源 
   */ 
   public synchronized void decreace() { 
     while (number == 0) { 
       try { 
         wait(); 
       } catch (interruptedexception e) { 
         e.printstacktrace(); 
       } 
     } 
     number--; 
     system.out.println(number); 
     notify(); 
   } 
 } 

者线程和消费者线程,并模拟多次生产和消费,即增加和减少公共资源的number值

java代码  

/** 
 * 生产者线程,负责生产公共资源 
 */ 
 public class producerthread implements runnable { 
   private publicresource resource; 
  
   public producerthread(publicresource resource) { 
     this.resource = resource; 
   } 
  
   @override 
   public void run() { 
     for (int i = 0; i < 10; i++) { 
       try { 
         thread.sleep((long) (math.random() * 1000)); 
       } catch (interruptedexception e) { 
         e.printstacktrace(); 
       } 
       resource.increace(); 
     } 
   } 
 } 
 /** 
 * 消费者线程,负责消费公共资源 
 */ 
 public class consumerthread implements runnable { 
   private publicresource resource; 
  
   public consumerthread(publicresource resource) { 
     this.resource = resource; 
   } 
  
   @override 
   public void run() { 
     for (int i = 0; i < 10; i++) { 
       try { 
         thread.sleep((long) (math.random() * 1000)); 
       } catch (interruptedexception e) { 
         e.printstacktrace(); 
       } 
       resource.decreace(); 
     } 
   } 
 } 

三,模拟多个生产者和消费者操作公共资源的情形,结果须保证是在允许的范围内。

java代码  

public class producerconsumertest { 
   public static void main(string[] args) { 
     publicresource resource = new publicresource(); 
     new thread(new producerthread(resource)).start(); 
     new thread(new consumerthread(resource)).start(); 
     new thread(new producerthread(resource)).start(); 
     new thread(new consumerthread(resource)).start(); 
     new thread(new producerthread(resource)).start(); 
     new thread(new consumerthread(resource)).start(); 
   } 
 } 

以上所述是小编给大家介绍的java生产者和消费者例子,希望对大家有所帮助