多线程通信（notify和wait升级CountDownLatch的使用）-----线程之间的实时通信

た入场券 2022-05-21 04:51 235阅读 0赞

上一篇看了notify和wait的作用，给线程之间提供了通信，但是也是存在一定的弊端，**就是不实时的问题**，也就是当t1线程的notify()向t2线程发出通知，由于notify不释放锁，导致结果t1线程执行完毕后，t2线程才会去执行。我们要的效果是：当t2线程接收到通知以后t2线程就开始执行，而不是等待t1执行完毕后才执行。

咱们采用的办法是：使用CountDownLatch这个类

package com.wuk.Demo;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    
    public class MyThread005 {
    
        private static volatile List<String> list=new ArrayList<String>();  
    
        public void add() {
    
            list.add("wuk");
        }
    
        public  int size() {
    
            return list.size();
        }
    
        public static void main(String[] args) {
    
            final CountDownLatch countDownLatch=new CountDownLatch(1);//1表示通知一次就可以了countDownLatch.countDown();
    
            MyThread005 myList=new MyThread005();
    
            Thread t1=new Thread(new Runnable() {
    
                @Override
                public void run() {
                    System.out.println("t1线程启动。。。。");
                    try {
                        for(int i=0;i<10;i++) {
    
                            myList.add();
                            System.out.println("线程"+Thread.currentThread().getName()+"向集合中添加一个元素了");
                            Thread.sleep(500);
                            if(myList.size()==5) {
    
                                System.out.println("线程"+Thread.currentThread().getName()+"已经发出通知。。。。。。。");
    
                                countDownLatch.countDown();
                            }
                        }
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            },"t1"); 
    
            Thread t2=new Thread(new Runnable() {
    
                @Override
                public void run() {
    
                    try {
                        System.out.println("t2启动。。。");
                        if(myList.size()!=5) {
                            System.out.println("t2等待。。。。");
                            countDownLatch.await();
                        }
                        System.out.println("当前线程：" + Thread.currentThread().getName() + "收到通知线程停止..");
                        throw new RuntimeException();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
            },"t2");
    
    
            t2.start();
            t1.start();
        }
    
    }

打印结果：

t2启动。。。
    t1线程启动。。。。
    t2等待。。。。
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了
    线程t1已经发出通知。。。。。。。
    线程t1向集合中添加一个元素了
    当前线程：t2收到通知线程停止..
    Exception in thread "t2" java.lang.RuntimeException
        at com.wuk.Demo.MyThread005$2.run(MyThread005.java:64)
        at java.lang.Thread.run(Unknown Source)
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了
    线程t1向集合中添加一个元素了

上面的打印可能有问题，就是：

线程t1已经发出通知。。。。。。。
    线程t1向集合中添加一个元素了

这个是打印的问题，因为打印也需要时间，不用管它。

**这样就达到我们想要的线程通信实时的效果了，也就是这边通知，那边马上就有响应了。**

发表评论取消回复

表情：

评论列表（有 0 条评论，235人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java多线程通信：wait(), notify()与CountDownLatch实战

在Java多线程中，`wait()`、`notify()`和`CountDownLatch`是用于线程间同步的关键工具。 1. `wait()`：当一个线程调用此方法

太过爱你忘了你带给我的痛/ 2024年10月25日 20:03/ 0 赞/ 14 阅读

相关 Java多线程通信：wait和notify编程

多线程编程是Java中常见的技术之一，而线程间的通信是多线程编程中的重要部分。在Java中，我们可以使用wait和notify方法实现线程间的通信。本文将详细介绍wait和no

你的名字/ 2023年10月16日 18:22/ 0 赞/ 2 阅读

相关多线程通信 wait和notify

一、概念线程是操作系统中独立的个体，这些线程如果不通过特殊的手段进行处理，就无法组成一个完整的整体。因此线程通信就称为组成一个整体的必须条件之一。当线程之间存在通

Love The Way You Lie/ 2023年08月17日 17:33/ 0 赞/ 110 阅读

相关线程间的通信 wait、notify

上一篇： [线程同步之synchronized关键字][synchronized] wait wait跟sleep方法的作用一样，也是让线程休眠，但是针对的对象不同

ゝ一纸荒年。/ 2022年10月06日 14:56/ 0 赞/ 179 阅读

相关多线程同步synchronized、通信wait、notify

/\ \ 生产者将产品交给店员，二消费者从店员处取走产品； \ 店员持有的产品数量不超过20，如果超过20叫生产者停一下,少于20就继续生产； \ 如果

末蓝、/ 2022年08月14日 05:39/ 0 赞/ 203 阅读

相关多线程编程-线程间通信.wait/notify（四）

多个线程通过共同访问一个变量的方式，也可以实现线程间通信，通过这种方式，线程要主动去读取一个共享变量，一方面需要加同步，另一方面花费了读取变量的时间，但是读取到的值是不是要想要

蔚落/ 2022年06月01日 01:12/ 0 赞/ 275 阅读

相关多线程之线程通信wait和notify的使用

使用wait和notify方法实现线程之间的通信，注意，这两个方法是Object类的方法，也就是说Java为所有的对象都提供的这两个方法。 1 wait和notify必须配合

ゝ一纸荒年。/ 2022年05月22日 08:07/ 0 赞/ 250 阅读

相关多线程通信（notify和wait升级CountDownLatch的使用）-----线程之间的实时通信

上一篇看了notify和wait的作用，给线程之间提供了通信，但是也是存在一定的弊端，就是不实时的问题，也就是当t1线程的notify()向t2线程发出通知，由于notify不

た入场券/ 2022年05月21日 04:51/ 0 赞/ 236 阅读

相关线程通信wait与notify

Wait/notify 可以实现线程间的通信 Wait方法，释放锁 Notify方法，不释放锁 Wait与notify方法必须配置synchronize使用

今天药忘吃喽~/ 2022年05月14日 02:53/ 0 赞/ 240 阅读

相关 java多线程（四）、线程通信wait() 、notify()

参考文档：[https://blog.csdn.net/boling\_cavalry/article/details/77793224][https_blog.csdn.ne

Love The Way You Lie/ 2022年04月02日 12:46/ 0 赞/ 334 阅读