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

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

发布时间 - 2026-01-11 01:16:04 点击率：次

生产者-消费者（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生产者和消费者例子，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对网站的支持！

# java # 生产者和消费者 # java实现生产者消费者 # Java 生产者/消费者问题实例详解 # 浅谈java线程中生产者与消费者的问题 # Java并发编程中的生产者与消费者模型简述 # java多线程解决生产者消费者问题 # java解决单缓冲生产者消费者问题示例 # JAVA生产者消费者(线程同步)代码学习示例 # 公共资源 # 多个 # 还想 # 小编 # 是在 # 走了 # 在此 # 出现在 # 给大家 # 满了 # 再去 # 另外一个 # 其中一个 # 解决方法 # 所述 # 给我留言 # 多线程 # 感谢大家 # 空了 # 时再

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251813 】【 AI营销90571 】

上一篇：2025年最佳射击游戏盘点：射击体验从未如此畅快

下一篇：乌鲁木齐银行定向采购 Oracle、IBM、Redhat

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：2025年最佳射击游戏盘点：射击体验从未如此畅快

下一篇：乌鲁木齐银行定向采购 Oracle、IBM、Redhat