JAVA多线程实现生产者消费者的实例详解

JAVA多线程实现生产者消费者的实例详解

下面的代码实现了生产者消费者的问题

Product.Java

package consumerProducer; 
 
public class Product { 
private String id; 
 
public String getId() { 
  return id; 
} 
 
public void setId(String id) { 
  this.id = id; 
} 
public Product(String id) 
{ 
  this.id=id; 
 
} 
public String toString() 
{ 
  return "product "+id;   
 
} 
 
} 

Pool.java

package consumerProducer; 
import java.util.*; 
public class Pool { 
private int number=0; 
 
private List<Product>products=new LinkedList<Product>(); 
 
 
public int getNumber() { 
  return number; 
} 
public void setNumber(int number) { 
  this.number = number; 
} 
public synchronized Product consumeProduct(){  //可以去掉synchronized关键字 
  if(products.size()>0) 
  {    Product p= products.get(0); 
    products.remove(0); 
    number--; 
    return p; 
 
  } 
  else 
    return null; 
} 
public synchronized void addProduct(Product p){  //可以去掉synchronized关键字 
       
      products.add(p); 
      number++; 
} 
 
} 

Consumer.java

package consumerProducer; 
 
public class Consumer implements Runnable { 
 private String id; 
  Pool pool; 
  public Consumer(String id,Pool pool) 
  { 
    this.id=id; 
    this.pool=pool; 
     
  } 
  @Override 
  public void run() { 
    while(!Thread.currentThread().interrupted()) 
    { 
      Product product=null; 
      synchronized(pool){ 
        while(pool.getNumber()<=0)//生产不足 
        { 
          try { 
            pool.wait();//生产者等待 
          } catch (InterruptedException e) { 
            // TODO Auto-generated catch block 
            e.printStackTrace(); 
          } 
         
       
          
        } 
         product=pool.consumeProduct(); 
      } 
        System.out.println("consuming "+id+product.toString()); 
        try { 
          Thread.sleep(1000); 
        } catch (InterruptedException e) { 
          // TODO Auto-generated catch block 
          e.printStackTrace(); 
        } 
         
       
       
       
    } 
  } 
 
} 

Producer.java

package consumerProducer; 
 
public class Producer implements Runnable{ 
  private int i_p=0; 
  private String id; 
  Pool pool; 
  int i=0; 
  public Producer(String id ,Pool pool) 
  { 
     
    this.id=id; 
    this.pool=pool; 
  } 
  public Product createProduct() 
  { 
     
    return new Product(String.valueOf(++i_p)); 
     
  } 
  @Override 
  public void run() { 
    // TODO Auto-generated method stub 
   while(!Thread.currentThread().interrupted()) 
   { 
     Product p=new Product(String.valueOf(++i_p)); 
     try { 
      Thread.sleep(1000); 
    } catch (InterruptedException e) { 
      // TODO Auto-generated catch block 
      e.printStackTrace(); 
    } 
     synchronized(pool) 
     { 
       pool.addProduct(p); 
       System.out.println("producer "+id+" adding product...."+p.toString()); 
       pool.notifyAll(); 
     }  
      
   } 
     
  } 
 
} 

Main.java

package consumerProducer; 
 
public class Main { 
 
  public static void main(String[] args) { 
    // TODO Auto-generated method stub 
    Pool pool=new Pool(); 
   for(int i=0;i<5;i++) 
   { 
     Thread consumer=new Thread(new Consumer("consumer "+i,pool)); 
     Thread producer=new Thread(new Producer("producer "+i,pool)); 
     consumer.start(); 
     producer.start(); 
      
   } 
  } 
 
} 

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# JAVA多线程实现生产者消费者的实例详解  # java  # 线程生产者与消费者的问题  # 基于Java 生产者消费者模式(详细分析)  # Java生产者消费者模式实例分析  # Java多种方式实现生产者消费者模式  # Java实现简易生产者消费者模型过程解析  # Java编程生产者消费者实现的四种方法  # 希望能  # 谢谢大家  # 多线程  # 实现了  # number  # int  # lt  # List  # util  # Pool  # product  # import  # br  # consumeProduct  # synchronized  # remove  # size  # setNumber  # products  # gt 

相关文章： 如何快速建站并高效导出源代码？  网站设计制作公司地址,网站建设比较好的公司都有哪些？  建站之星客服服务时间及联系方式如何？  高端智能建站公司优选：品牌定制与SEO优化一站式服务  c# 在ASP.NET Core中管理和取消后台任务  岳西云建站教程与模板下载_一站式快速建站系统操作指南  Swift开发中switch语句值绑定模式  如何在万网自助建站平台快速创建网站？  文字头像制作网站推荐软件,醒图能自动配文字吗？  C#怎么创建控制台应用 C# Console App项目创建方法  官网自助建站系统：SEO优化+多语言支持，快速搭建专业网站  简易网站制作视频教程,使用记事本编写一个简单的网页html文件？  东莞专业网站制作公司有哪些,东莞招聘网站哪个好？  网站代码制作软件有哪些,如何生成自己网站的代码？  实现虚拟支付需哪些建站技术支撑？  Python多线程使用规范_线程安全解析【教程】  如何在沈阳梯子盘古建站优化SEO排名与功能模块？  ,交易猫的商品怎么发布到网站上去？  香港服务器选型指南：免备案配置与高效建站方案解析  在线ppt制作网站有哪些,请推荐几个好的课件下载的网站？  网站制作多少钱一个,建一个论坛网站大约需要多少钱？  ,怎么用自己头像做动态表情包？  微网站制作教程,不会写代码，不会编程，怎么样建自己的网站？  如何通过西部数码建站助手快速创建专业网站？  c# await 一个已经完成的Task会发生什么  建站主机如何选？性能与价格怎样平衡？  教学网站制作软件,学习*后期制作的网站有哪些？  ppt制作免费网站有哪些,ppt模板免费下载网站？  建站上传速度慢？如何优化加速网站加载效率？  平台云上自主建站：模板化设计与智能工具打造高效网站  如何用y主机助手快速搭建网站？  清单制作人网站有哪些,近日“兴风作浪的姑奶奶”引起很多人的关注这是什么事情？  公司网站制作费用多少,为公司建立一个网站需要哪些费用？  建站之星24小时客服电话如何获取？  广州网站建站公司选择指南：建站流程与SEO优化关键词解析  昆明网站制作哪家好,昆明公租房申请网上登录入口？  如何通过云梦建站系统实现SEO快速优化？  怎么制作一个起泡网,水泡粪全漏粪育肥舍冬季氨气超过25ppm，可以有哪些措施降低舍内氨气水平？  IOS倒计时设置UIButton标题title的抖动问题  c++怎么使用类型萃取type_traits_c++ 模板元编程类型判断【方法】  Bpmn 2.0的XML文件怎么画流程图  大连网站设计制作招聘信息,大连投诉网站有哪些？  网站制作公司广州有几家,广州尚艺美发学校网站是多少？  攀枝花网站建设,攀枝花营业执照网上怎么年审？  个人网站制作流程图片大全,个人网站如何注销？  如何用低价快速搭建高质量网站？  太平洋网站制作公司,网络用语太平洋是什么意思？  广州网站设计制作一条龙,广州巨网网络科技有限公司是干什么的？  建站主机是否等同于虚拟主机？  ,制作一个手机app网站要多少钱？