13 使用Latch(门闩)代替wait notify来进行通知

冷不防 2024-04-18 17:45 29阅读 0赞

/**
     * 曾经的面试题：（淘宝？）
     * 实现一个容器，提供两个方法，add，size
     * 写两个线程，线程1添加10个元素到容器中，线程2实现监控元素的个数，当个数到5个时，线程2给出提示并结束
     * 
     * 给lists添加volatile之后，t2能够接到通知，但是，t2线程的死循环很浪费cpu，如果不用死循环，该怎么做呢？
     * 
     * 这里使用wait和notify做到，wait会释放锁，而notify不会释放锁
     * 需要注意的是，运用这种方法，必须要保证t2先执行，也就是首先让t2监听才可以
     * 
     * 阅读下面的程序，并分析输出结果
     * 可以读到输出结果并不是size=5时t2退出，而是t1结束时t2才接收到通知而退出
     * 想想这是为什么？
     * 
     * notify之后，t1必须释放锁，t2退出后，也必须notify，通知t1继续执行
     * 整个通信过程比较繁琐
     * 
     * 使用Latch（门闩）替代wait notify来进行通知
     * 好处是通信方式简单，同时也可以指定等待时间
     * 使用await和countdown方法替代wait和notify
     * CountDownLatch不涉及锁定，当count的值为零时当前线程继续运行
     * 当不涉及同步，只是涉及线程通信的时候，用synchronized + wait/notify就显得太重了
     * 这时应该考虑countdownlatch/cyclicbarrier/semaphore
     * @author mashibing
     */
    package yxxy.c_019;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.TimeUnit;
    
    public class MyContainer5 {
    
    	// 添加volatile，使t2能够得到通知
    	volatile List lists = new ArrayList();
    
    	public void add(Object o) {
    		lists.add(o);
    	}
    
    	public int size() {
    		return lists.size();
    	}
    
    	public static void main(String[] args) {
    		MyContainer5 c = new MyContainer5();
    		//门闩(当这个1变成0的时候，这个门闩就开了)
    		CountDownLatch latch = new CountDownLatch(1);
    
    		new Thread(() -> {
    			System.out.println("t2启动");
    			if (c.size() != 5) {
    				try {
    					//门闩等待不需要锁定任何对象
    					latch.await();
    					
    					//也可以指定等待时间
    					//latch.await(5000, TimeUnit.MILLISECONDS);
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    			}
    			System.out.println("t2 结束");
    
    		}, "t2").start();
    
    		try {
    			TimeUnit.SECONDS.sleep(1);
    		} catch (InterruptedException e1) {
    			e1.printStackTrace();
    		}
    
    		new Thread(() -> {
    			System.out.println("t1启动");
    			for (int i = 0; i < 10; i++) {
    				c.add(new Object());
    				System.out.println("add " + i);
    
    				if (c.size() == 5) {
    					// 打开门闩，让t2得以执行
    					latch.countDown();
    				}
    
    				try {
    					TimeUnit.SECONDS.sleep(1);
    				} catch (InterruptedException e) {
    					e.printStackTrace();
    				}
    			}
    
    		}, "t1").start();
    
    	}
    }

转载于:https://my.oschina.net/u/4131327/blog/3074391

发表评论取消回复

表情：

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

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

相关阅读

相关 13 使用Latch(门闩)代替wait notify来进行通知

/** * 曾经的面试题：（淘宝？） * 实现一个容器，提供两个方法，add，size * 写两个线程，线程1添加10个元素到容器中，...

冷不防/ 2024年04月18日 17:45/ 0 赞/ 30 阅读

相关 JAVA锁之wait,notify(wait会释放锁，notify仅仅只是通知，不释放锁)

wait是指在一个已经进入了同步锁的线程内，让自己暂时让出同步锁，以便其他正在等待此锁的线程可以得到同步锁并运行，只有其他线程调用了notify方法（notify并不释放锁，只

╰半橙微兮°/ 2023年06月19日 06:58/ 0 赞/ 23 阅读

相关 Java多线程——wait(),notify(),notifyAll()等待通知机制

Java多线程——wait(),notify(),notifyAll()等待通知机制这里所说的wait()，notify()，notifyAll()都是Objec

╰+攻爆jí腚メ/ 2023年06月06日 08:19/ 0 赞/ 1 阅读

相关 UNIX(多线程)：13---condition_variable、wait、notify_one、notify_all

条件变量std::condition\_variable、wait()、notify\_one() 线程A: 等待一个条件满足线程B: 专门往消息队列中放入

浅浅的花香味﹌/ 2023年01月03日 04:06/ 0 赞/ 106 阅读

相关 wait和notify使用API

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

谁践踏了优雅/ 2022年12月03日 05:24/ 0 赞/ 159 阅读

相关 java notify wait_java中wait/notify机制

通常，多线程之间需要协调工作。例如，浏览器的一个显示图片的线程displayThread想要执行显示图片的任务，必须等待下载线程 downloadThread将该图片下载完毕。

阳光穿透心脏的1/2处/ 2022年11月06日 00:56/ 0 赞/ 187 阅读

相关 Java 同步(Synchronization)，等待(wait)通知(notify, notifyall)

Java关于同步，等待，通知 > 本文翻译Java语言规范中同步部分章节，翻译有问题请参考原文，本文仅在于自己理解Java的wait的原理。 > 原文链接([http

╰+哭是因爲堅強的太久メ/ 2022年09月30日 07:06/ 0 赞/ 163 阅读

相关 Wait-Notify机制

http://www.ticmy.com/?p=219 Wait-Notify机制可以说是实现阻塞操作较为高效的一种方式。虽然在实际中鼓励使用类库中已有的满足条件的类，或基于

矫情吗；*/ 2022年07月16日 11:27/ 0 赞/ 222 阅读

相关 java锁之wait,notify(wait会释放锁，notify仅仅只是通知，不释放锁)

原文地址：[http://blog.csdn.net/azhegps/article/details/63031562][http_blog.csdn.net_azhegps_

妖狐艹你老母/ 2022年05月29日 06:41/ 0 赞/ 320 阅读

相关 wait与notify

下面继续来记录多线程相关，今天记录并分享的都略微有点偏概念，但是看完之后绝对有助于提高读多线程相关的使用能力呦：线程有新建、就绪、运行、阻塞、死亡五种状态。下面就来说

深碍√TFBOYSˉ_/ 2021年09月23日 11:10/ 0 赞/ 311 阅读