我们专注攀枝花网站设计 攀枝花网站制作 攀枝花网站建设
成都网站建设公司服务热线：400-028-6601

网站建设知识

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

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

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://mswzjz.cn/article/jggegc.html

        

    

    


        
其他资讯


        

    







    


        


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


            *主要业务范围包括：高端网站建设， 集团网站建设(网站建设网站制作)找网站建设公司就上四川攀枝花网站建设。

            


                

                

                

                提交需求

            


        


    


    


        


            
    

                
    联系我们
    

                028-86922220

                
  • 手机：13518219792
    • 

                
  • 地址：成都市太升南路288号锦天国际A幢1002号
    • 

                
  • 

                
  • 24小时服务热线：400-028-6601
    • 

            


            
    

                
    网站建设服务
    

                
  • 网页设计
    • 

                
  • 网站制作
    • 

                
  • 网站开发
    • 

            


            
    

                
    网站推广服务
    

                
  • 营销网站建设
    • 

                
  • 百度快速排名
    • 

                
  • 整站网站推广
    • 

            


            
    

                
    网站运维服务
    

                
  • 基础维护
    • 

                
  • 网站改版
    • 

                
  • 网站维护
    • 

            


            
    

                
    FOLLOW US
    

                
  • 

                
  • 

                    
    微信二维码
    

                    
    微信二维码
    

                
    • 

            


        


        


            友情链接：

            域名注册   青羊总部基地   国泰民安消防   seo推广公司   犀浦防纹窗   营销网站定位   乐山做网站   成都画册设计公司   网上商城开发   成都网站推广   
        


    


    


        


            


                Copyright © 2022  四川攀枝花网站建设公司     四川攀枝花网站建设公司-选我们！四川专业的攀枝花网站制作公司！

            


            


                All Rights Reserved 版权所有 蜀ICP备2024097831号-1