CountDownLatch实时通信

向右看齐 2022-05-14 02:54 193阅读 0赞

### CountDownLatch ###

可以实现线程，实时通信

Await方法，等待  
countDown方法，通知

### 区别 ###

CountDownLatch，不需要配合synchronize使用  
Wait/notify，必须配合synchronize使用

package com.bjsxt.base.conn008;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Queue;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.LinkedBlockingDeque;
    import java.util.concurrent.LinkedBlockingQueue;
    /** * wait notfiy 方法，wait释放锁，notfiy不释放锁 * */
    public class ListAdd2 { 
        private volatile static List list = new ArrayList();    
    
        public void add(){
            list.add("bjsxt");
        }
        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();
    
            final CountDownLatch countDownLatch = new CountDownLatch(1);
    
            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("已经发出通知..");
                                    countDownLatch.countDown();
                                    //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 {
                                //System.out.println("t2进入...");
                                //lock.wait();
                                countDownLatch.await();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                        System.out.println("当前线程：" + Thread.currentThread().getName() + "收到通知线程停止..");
                        throw new RuntimeException();
                    //}
                }
            }, "t2");   
    
            t2.start();
            t1.start();
    
        }
    
    }

运行  
![这里写图片描述][70]  
线程t1，添加了5个元素，发出通知  
此时，线程t2会立即执行，不用等到线程t1执行完毕

注意  
这里，1表示通知的次数  
通知1次，就会唤醒线程t2

[70]: /images/20220514/f4fb7f68509f4d39add985d2e3560fcf.png