快上网建站品牌

13518219792

Java通过wait()和notifyAll()方法实现线程间通信

本文实例为大家分享了Java实现线程间通信的具体代码，供大家参考，具体内容如下

创新互联主要从事成都做网站、成都网站设计、网页设计、企业做网站、公司建网站等业务。立足成都服务深泽,10多年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:13518219792

Java代码（使用了2个内部类）：

package Threads;

import java.util.LinkedList;

/**
 * Created by Frank
 */
public class ProdCons {
 protected LinkedList list = new LinkedList<>();
 protected int max;
 protected boolean done = false;

 public static void main(String[] args) throws InterruptedException {
  ProdCons prodCons = new ProdCons(100, 3, 4);
  Thread.sleep(5 * 1000);
  synchronized (prodCons.list) {
   prodCons.done = true;
   try {
    prodCons.notifyAll();
   } catch (Exception ex) {
   }
  }
 }

 private ProdCons(int maxThreads, int nP, int nC) {
  this.max = maxThreads;
  for (int i = 0; i < nP; i++) {
   new Producer().start();
  }
  for (int i = 0; i < nC; i++) {
   new Consumer().start();
  }
 }

 class Producer extends Thread {
  public void run() {
   while (true) {
    Object justProduced = null;
    try {
     justProduced = getObj();
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    synchronized (list) {
     while (list.size() == max) {
      try {
       list.wait();
      } catch (InterruptedException e) {
       System.out.println("Producer INTERRUPTED");
      }
     }
     list.addFirst(justProduced);
     list.notifyAll();
     System.out.println("Produced 1;List size now " + list.size());
     if (done) {
      break;
     }
    }
   }
  }
 }

 class Consumer extends Thread {
  public void run() {
   while (true) {
    Object object = null;
    synchronized (list) {
     if (list.size() == 0) {
      try {
       list.wait();
      } catch (InterruptedException e) {
       System.out.println("Consumer INTERRUPTED");
      }
     }
     if (list.size() > 0) {
      object = list.removeLast();
     }
     list.notifyAll();
     System.out.println("List size now " + list.size());
     if (done) {
      break;
     }
    }
    if (null != object) {
     System.out.println("Consuming object " + object);
    }
   }
  }
 }

 private Object getObj() throws InterruptedException {
  Thread.sleep(1000);
  return new Object();
 }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持创新互联。
            
            
                                

                    名称栏目：Java通过wait()和notifyAll()方法实现线程间通信                    

                    文章链接：http://csdahua.cn/article/jggegc.html
                
                

                    

                    

                        
扫二维码与项目经理沟通

                        
我们在微信上24小时期待你的声音

                        
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流

                    

                

                

                    
其他资讯

                    
                

            
        
        

            

                
                    
行业动态

                    
企业网站建设的重要性！

                    
现在虽然是移动互联网时代，但企业网站依然重要，包含PC站点，移动站。可以说企业网站关系企业的未来发展和前途，尤其对中小企业更是如此，一些中小企业老板，对自己的名片很在乎，因为这是个门面。...

                
            

            

                
服务项目

                
            

            

                
 联系吧 在百度地图上找到我们 

                
电话：13518219792

                
如遇占线或暂未接听请拨：136xxx98888

                
 业务咨询 技术咨询 售后服务 

            

        

        
    
    

        

            

                

                    
网站制作

                    
梓潼网站制作公司
成都网站制作
手机网站制作
绵阳网站制作
                

                

                    
网站建设

                    
外贸网站建设
成都品牌网站建设
营销型网站建设
江油网站建设
                

                

                    
网站设计

                    
盐亭网站设计
达州网站设计
成都企业网站设计
高端定制网站设计
                

                

                    
联系我们

                    
电话：13518219792

                    
邮箱：631063699@qq.com

                    
地址：成都青羊区锦天国际1002号

                    
网址：www.csdahua.cn

                

                

                    

                    

                        
 
                            
微信二维码

                        

                    

                

            

        

        

            
        

    

    

        

            
 Copyright © 2002-2023 www.csdahua.cn 快上网建站品牌 QQ：244261566 版权所有 备案号：蜀ICP备19037934号