我们专注孝感网站设计 孝感网站制作 孝感网站建设
成都网站建设公司服务热线：18982081108

网站建设知识

十年网站开发经验 + 多家企业客户 + 靠谱的建站团队

量身定制 + 运营维护+专业推广+无忧售后，网站问题一站解决

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://www.ytofo.com/article/jggegc.html
        
    
    

        
其他资讯

        
    




    

        

            
免费获取网站设计制作与品牌网站建设策划方案报价

            网站设计 + 品牌建站，策划方案 + 精准报价，现在免费领！品牌要升级，官网先发力！免费领取网站设计制作方案 + 精准报价，专业团队帮你落地
            

                
                
                
                提交需求
            

        

    

    

        

            
    
                
    联系我们
    
                18980820575
                
  • 手机：13518219792
    • 
                
  • 地址：湖北孝感市大悟城关镇鄂北物流城13栋125号
    • 
                
  • 
                
  • 24小时服务热线：18982081108
    • 
            

            
    
                
    网站建设服务
    
                
  • 网页设计
    • 
                
  • 网站制作
    • 
                
  • 网站开发
    • 
            

            
    
                
    网站推广服务
    
                
  • 营销网站建设
    • 
                
  • 百度快速排名
    • 
                
  • 整站网站推广
    • 
            

            
    
                
    网站运维服务
    
                
  • 基础维护
    • 
                
  • 网站改版
    • 
                
  • 网站维护
    • 
            

            
    
                
    FOLLOW US
    
                
  • 
                
  • 
                    
    微信二维码
    
                    
    微信二维码
    
                
    • 
            

        

        

            友情链接：
            眉山维修发电机   营山产后护理   云锦斋建筑   网站空间   关键词排名优化   成都服务器托管   关键词排名   四川德阳主机托管   75222.cn   联通机柜租用           

    

    

        

            

                Copyright © 2025  湖北孝感网站建设公司     湖北孝感网站建设公司-选我们！湖北专业的孝感网站制作公司！
            

            

                All Rights Reserved 版权所有 鄂ICP备2025125038号-8