Java多线程中线程间的通信实例详解

Java多线程中线程间的通信

一、使用while方式来实现线程之间的通信

package com.ietree.multithread.sync;

import java.util.ArrayList;
import java.util.List;

public class MyList {
  
  private volatile static List list = new ArrayList();

  public void add() {
    list.add("apple");
  }

  public int size() {
    return list.size();
  }

  public static void main(String[] args) {

    final MyList list1 = new MyList();

    Thread t1 = new Thread(new Runnable() {
      @Override
      public void run() {
        try {
          for (int i = 0; i < 10; i++) {
            list1.add();
            System.out.println("当前线程：" + Thread.currentThread().getName() + "添加了一个元素..");
            Thread.sleep(500);
          }
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    }, "t1");

    Thread t2 = new Thread(new Runnable() {
      @Override
      public void run() {
        while (true) {
          if (list1.size() == 5) {
            System.out.println("当前线程收到通知：" + Thread.currentThread().getName() + " list size = 5 线程停止..");
            throw new RuntimeException();
          }
        }
      }
    }, "t2");

    t1.start();
    t2.start();
  }
}

程序输出：

当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
Exception in thread "t2" 当前线程收到通知：t2 list size = 5 线程停止..
java.lang.RuntimeException
  at com.ietree.multithread.sync.MyList$2.run(MyList.java:43)
  at java.lang.Thread.run(Unknown Source)
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..

理解：线程Thread2不停地通过while语句检测这个条件(list.size()==5)是否成立 ，从而实现了线程间的通信。但是这种方式会浪费CPU资源。

二、wait notfiy 方法实现多线程中线程之间的通信

使用这种方式实现线程通信需要注意：wait和notify必须配合synchronized关键字使用，wait方法释放锁，notify方法不释放锁。并且在这个例子中必须是Thread2先执行才可以。

package com.ietree.multithread.sync;

import java.util.ArrayList;
import java.util.List;

public class ListAdd3 {
  private volatile static List list = new ArrayList();

  public void add() {
    list.add("apple");
  }

  public int size() {
    return list.size();
  }

  public static void main(String[] args) {

    final ListAdd2 list2 = new ListAdd2();

    // 1 实例化出来一个 lock
    // 当使用wait 和 notify 的时候 ， 一定要配合着synchronized关键字去使用
    final Object lock = new Object();

    Thread t1 = new Thread(new Runnable() {
      @Override
      public void run() {
        try {
          synchronized (lock) {
            for (int i = 0; i < 10; i++) {
              list2.add();
              System.out.println("当前线程：" + Thread.currentThread().getName() + "添加了一个元素..");
              Thread.sleep(500);
              if (list2.size() == 5) {
                System.out.println("已经发出通知..");
                //不释放锁，遇到size=5时还是继续执行
                lock.notify();
              }
            }
          }
        } catch (InterruptedException e) {
          e.printStackTrace();
        }

      }
    }, "t1");

    Thread t2 = new Thread(new Runnable() {
      @Override
      public void run() {
        synchronized (lock) {
          if (list2.size() != 5) {
            try {
              //释放锁，让其他线程执行
              lock.wait();
            } catch (InterruptedException e) {
              e.printStackTrace();
            }
          }
          System.out.println("当前线程：" + Thread.currentThread().getName() + "收到通知线程停止..");
          throw new RuntimeException();
        }
      }
    }, "t2");

    t2.start();
    t1.start();

  }
}

程序输出：

当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
已经发出通知..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t2收到通知线程停止..
Exception in thread "t2" java.lang.RuntimeException
  at com.ietree.multithread.sync.ListAdd3$2.run(ListAdd3.java:59)
  at java.lang.Thread.run(Unknown Source)

三、使用CountDownLatch类来实现多线程中线程之间的实时通信

package com.ietree.multithread.sync;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;

public class ListAdd2 {
  private volatile static List list = new ArrayList();

  public void add() {
    list.add("apple");
  }

  public int size() {
    return list.size();
  }

  public static void main(String[] args) {

    final ListAdd2 list2 = new ListAdd2();

    final CountDownLatch countDownLatch = new CountDownLatch(1);

    Thread t1 = new Thread(new Runnable() {
      @Override
      public void run() {
        try {
          for (int i = 0; i < 10; i++) {
            list2.add();
            System.out.println("当前线程：" + Thread.currentThread().getName() + "添加了一个元素..");
            Thread.sleep(500);
            if (list2.size() == 5) {
              System.out.println("已经发出通知..");
              countDownLatch.countDown();
            }
          }
          // }
        } catch (InterruptedException e) {
          e.printStackTrace();
        }

      }
    }, "t1");

    Thread t2 = new Thread(new Runnable() {
      @Override
      public void run() {
        if (list2.size() != 5) {
          try {
            countDownLatch.await();
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        System.out.println("当前线程：" + Thread.currentThread().getName() + "收到通知线程停止..");
        throw new RuntimeException();
      }
    }, "t2");

    t2.start();
    t1.start();

  }
}

程序输出：

当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
已经发出通知..
Exception in thread "t2" 当前线程：t1添加了一个元素..
当前线程：t2收到通知线程停止..
java.lang.RuntimeException
  at com.ietree.multithread.sync.ListAdd2$2.run(ListAdd2.java:56)
  at java.lang.Thread.run(Unknown Source)
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..

 四、使用多线程模拟一个队列

package com.ietree.multithread.sync;

import java.util.LinkedList;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

public class MyQueue {

  // 1、定义一个盛装元素集合
  private LinkedList<Object> list = new LinkedList<Object>();

  // 2、定义一个计数器
  private AtomicInteger count = new AtomicInteger();

  // 3、指定上限和下限
  private final int minSize = 0;
  private final int maxSize;

  // 4、构造方法初始化大小
  public MyQueue(int size) {
    this.maxSize = size;
  }

  // 5、初始化一个对象用于加锁
  private Object lock = new Object();

  // put(anObject): 把anObject加到BlockingQueue里,如果BlockQueue没有空间,则调用此方法的线程被阻断，直到BlockingQueue里面有空间再继续.
  public void put(Object obj) {
    synchronized (lock) {
      if (count.get() == this.maxSize) {
        try {
          lock.wait();
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
      // 1、加入元素
      list.add(obj);
      // 2、计数器累加
      count.incrementAndGet();
      // 3、通知（唤醒）另外一个线程
      lock.notify();
      System.out.println("新加入的元素为：" + obj);
    }
  }

  // take: 取走BlockingQueue里排在首位的对象,若BlockingQueue为空,阻断进入等待状态直到BlockingQueue有新的数据被加入.
  public Object take() {
    Object ret = null;
    synchronized (lock) {
      while (count.get() == this.minSize) {
        try {
          lock.wait();
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
      // 1、做移除元素操作
      ret = list.removeFirst();
      // 2、计数器作递减操作
      count.decrementAndGet();
      // 3、唤醒另外一个操作
      lock.notify();
    }

    return ret;
  }

  // 获取长度
  public int getSize() {
    return this.count.get();
  }

  public static void main(String[] args) {

    final MyQueue mq = new MyQueue(5);
    mq.put("a");
    mq.put("b");
    mq.put("c");
    mq.put("d");
    mq.put("e");

    System.out.println("当前容器的长度:" + mq.getSize());

    Thread t1 = new Thread(new Runnable() {
      @Override
      public void run() {
        mq.put("f");
        mq.put("g");
      }
    }, "t1");

    t1.start();

    Thread t2 = new Thread(new Runnable() {
      @Override
      public void run() {
        Object o1 = mq.take();
        System.out.println("移除的元素为:" + o1);
        Object o2 = mq.take();
        System.out.println("移除的元素为:" + o2);
      }
    }, "t2");

    try {
      TimeUnit.SECONDS.sleep(2);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }

    t2.start();
  }
}

程序输出：

新加入的元素为：a
新加入的元素为：b
新加入的元素为：c
新加入的元素为：d
新加入的元素为：e
当前容器的长度:5
移除的元素为:a
移除的元素为:b
新加入的元素为：f
新加入的元素为：g

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# Java多线程中线程间的通信  # java线程通信  # Java线程间的通信方式详解  # 深入理解JAVA多线程之线程间的通信方式  # java多线程实现服务器端与多客户端之间的通信  # 详谈java线程与线程、进程与进程间通信  # 浅析Java中如何实现线程之间通信  # 深入解析Java的线程同步以及线程间通信  # java线程间通信的通俗解释及代码示例  # java多线程编程学习(线程间通信)  # Java中实现线程间通信的实例教程  # 移除  # 多线程  # 另外一个  # 来实现  # 在这个  # 希望能  # 才可以  # 谢谢大家  # 排在  # 首位  # 需要注意  # 为空  # 取走  # 加锁  # 实现了  # 不停地  # RuntimeException  # start  # lt  # run 

相关文章： 北京制作网站的公司,北京铁路集团官方网站？  如何通过西部建站助手安装IIS服务器？  小建面朝正北，A点实际方位是否存在偏差？  C++时间戳转换成日期时间的步骤和示例代码  三星网站视频制作教程下载,三星w23网页如何全屏？  如何彻底卸载建站之星软件？  建站之星导航配置指南：自助建站与SEO优化全解析  建站之星安装提示数据库无法连接如何解决？  建站主机选哪家性价比最高？  如何制作一个表白网站视频,关于勇敢表白的小标题？  ,如何利用word制作宣传手册？  如何在IIS7上新建站点并设置安全权限？  如何选择高效响应式自助建站源码系统？  唐山网站制作公司有哪些,唐山找工作哪个网站最靠谱？  如何通过服务器快速搭建网站？完整步骤解析  猪八戒网站制作视频,开发一个猪八戒网站，大约需要多少？或者自己请程序员，需要什么程序员，多少程序员能完成？  建站主机选虚拟主机还是云服务器更好？  高端建站如何打造兼具美学与转化的品牌官网？  宝塔建站教程：一键部署配置流程与SEO优化实战指南  建站之星代理如何获取技术支持？  如何通过IIS搭建网站并配置访问权限？  广州营销型建站服务商推荐：技术优势与SEO优化解析  宿州网站制作公司兴策,安徽省低保查询网站？  如何通过老薛主机一键快速建站？  哈尔滨网站建设策划,哈尔滨电工证查询网站？  常州企业网站制作公司,全国继续教育网怎么登录？  如何规划企业建站流程的关键步骤？  网页设计与网站制作内容,怎样注册网站？  济南专业网站制作公司,济南信息工程学校怎么样？  制作网站外包平台,自动化接单网站有哪些？  Swift中swift中的switch 语句  建站之星备案是否影响网站上线时间？  如何构建满足综合性能需求的优质建站方案？  建站之星代理平台如何选择最佳方案？  常州自助建站：操作简便模板丰富，企业个人快速搭建网站  如何用景安虚拟主机手机版绑定域名建站？  nginx修改上传文件大小限制的方法  潍坊网站制作公司有哪些,潍坊哪家招聘网站好？  如何通过NAT技术实现内网高效建站？  简历在线制作网站免费版,如何创建个人简历？  如何快速搭建支持数据库操作的智能建站平台？  完全自定义免费建站平台：主题模板在线生成一站式服务  微网站制作教程,我微信里的网站怎么才能复制到浏览器里？  如何快速生成凡客建站的专业级图册？  如何选择香港主机高效搭建外贸独立站？  建站主机与虚拟主机有何区别？如何选择最优方案？  小型网站建站如何选择虚拟主机？  攀枝花网站建设,攀枝花营业执照网上怎么年审？  东莞专业网站制作公司有哪些,东莞招聘网站哪个好？  建站之星后台管理：高效配置与模板优化提升用户体验