JAVA多线程实现生产者消费者的实例详解_网络技术

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

发布时间 - 2026-01-11 01:48:26 点击率：次

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

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

上一篇：匠心独运：探索领先网页设计公司的创意之路

下一篇：如何在CentOS上解决PyTorch的依赖冲突

相关栏目网站优化
网络推广
网络技术
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

上一篇：匠心独运：探索领先网页设计公司的创意之路

下一篇：如何在CentOS上解决PyTorch的依赖冲突