成都创新互联网站制作重庆分公司

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



    
其他资讯

    




    

        

            
        

        

            
全国免费咨询:

            400-028-6601
            
业务咨询：028-86922220 / 13518219792

            
节假值班：18980820575 / 13518219792

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

        

    

    

        

            
Copyright © 成都创新互联科技有限公司重庆分公司  渝ICP备2021005571号

            
        

    

    

        

            友情链接:：
            成都网站建设
            重庆网站建设
            四川网站建设
            重庆建设网站
            移动服务器托管
            成都服务器托管
            云服务器
            广告设计制作
            重庆网页设计
            重庆做网站
            重庆网站制作
            重庆网站建设
            重庆网站公司
            渝中网站制作
            重庆网站设计
        

    





    




    

        

            
                
                
在线咨询

            
        

    

    

        
微信咨询

        

    

    

        
电话咨询

        

            
028-86922220（工作日）

            
18980820575（7×24）

        

    

    

        

            
                
提交需求

            
        

    

    

        

            
                
返回顶部