当前位置: 首页 > news >正文

并发编程学习(四):wait()、nitify()

1、wait、notify原理 

  •  Owner 线程发现条件不满足,调用wait()方法,即可进入WaitSet,变为WAITING 状态。
  • BLOCKED和WAITING的线程都处于阻塞状态,不占用CPU时间片。
  • BLOCKED线程会在Owner线程释放锁时唤醒。
  • WAITING线程会在Owner线程调用notify()或 notifyAll()时唤醒,但唤醒后并不意味着立刻获得锁,仍需进入EntryList重新竞争。

2、API介绍 

线程通信:wait() / notify() / notifyAll() 此三个方法定义在Object类中的。
  • obj.wait() 让进入object监视器的线程 到waitset等待。
  • obj.notify()在object上正在waitSet等待的线程挑一个唤醒。
  • obj.notifyAll()让object上正在waitSet等待的线程全部唤醒。

它们都是线程之间进行协作的手段,都属于Object对象的方法。必须获得此对象obj的锁,才能调用这几个方法

wait() 方法会释放对象的锁,进入WaitSet等待区(无限制等待,直到notify为止),从而然其他线程有机会获取到对象锁。

wait(long n)有时限的等待,到n毫秒后结束等待,或是被notify。 

未获得锁,直接调用wait()会报错。代码示例:

notify() / notifyAll()代码示例如下:

    final static Object obj = new Object();

    public static void main(String[] args) {

        new Thread(() -> {
            synchronized(obj) {
                log.debug("执行...");
                try {
                    obj.wait(); // 让线程在obj上一直等待下去
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                log.debug("其它代码...");
            }

        },"t1").start();

        new Thread(() -> {
            synchronized(obj) {
                log.debug("执行...");
                try {
                    obj.wait(); // 让线程在obj上一直等待下去
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                log.debug("其它代码...");
            }

        },"t2").start();

        // 主线程两秒后执行
        try {
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        log.debug("唤醒obj上的其它线程");
        synchronized (obj) {
//            obj.notify(); // 唤醒obj上随机一个线程
            obj.notifyAll(); // 唤醒obj上所有等待线程
        }

    }

obj.notify()代码执行结果:

14:15:50.663 [t1] DEBUG com.example.common.MagicNumberUtilsTests - 执行...
14:15:50.663 [t2] DEBUG com.example.common.MagicNumberUtilsTests - 执行...
14:15:52.673 [main] DEBUG com.example.common.MagicNumberUtilsTests - 唤醒obj上的其它线程
14:15:52.673 [t1] DEBUG com.example.common.MagicNumberUtilsTests - 其它代码...

obj.notifyAll()代码执行结果:

14:09:31.945 [t1] DEBUG com.example.common.MagicNumberUtilsTests - 执行...
14:09:31.949 [t2] DEBUG com.example.common.MagicNumberUtilsTests - 执行...
14:09:33.959 [main] DEBUG com.example.common.MagicNumberUtilsTests - 唤醒obj上的其它线程
14:09:33.959 [t2] DEBUG com.example.common.MagicNumberUtilsTests - 其它代码...
14:09:33.959 [t1] DEBUG com.example.common.MagicNumberUtilsTests - 其它代码...        

3、wait、notify的正确使用 

3.1、sleep(long n) 和wait(long n) 的区别

  1. sleep是Thread中的静态方法;而wait是Object中的方法。
  2. sleep不需要强制和synchronized配合使用;但wait需要和synchronized一起使用。
  3. sleep在睡眠的同时,不会释放对象锁;但wait在等待的时候会释放对象锁。
  4. 都调用这两个方法后,调用的当前线程都会进入:TIMED_WAITING状态。

3.2、正确使用格式

   final static Object lock = new Object();

// 干活线程
synchronized(lock) {
    while(条件不成立) {
        lock.wait();
    }
    // 干活
}

// 另一个线程
synchronized(lock) {
    lock.notifyAll();
}

相关文章:

  • React基础知识(事件处理、受控组件与非受控组件、高阶函数、组件的生命周期)(三)
  • 制作嵌入式根文件系统
  • js获取某一时间到现在的总时间以及svg图标统一管理方法的封装
  • 编程艺术之变成原则
  • 高品质蓝牙耳机排行榜,值得入手的四款蓝牙耳机分享
  • 车载以太网 - 初识DoIP - 01
  • Java -- OSS对象存储服务(Object Storage Service,简称 OSS)文件服务器
  • 【云原生 | 48】Etcd集群管理
  • “0基础、学历无优势、逻辑能力一般……”能转行做程序员吗?
  • 【C++】多态(万字详解) —— 条件 | 虚函数重写 | 抽象类 | 多态的原理
  • Vue:从组件开始学习
  • Python find()、rfind()方法
  • Android -- 每日一问:如何实现自定义View?
  • 【模型推理加速系列】07: 以BERT为例全面评测各种推理加速方案
  • 【Python】Numpy中的Gumbel分布和Logistic分布
  • UID走私:一种在线跟踪用户的新技术
  • 面向对象的软件工程
  • Android 11.0 SystemUI 音量条UI定制的功能(一)
  • 【Java基础知识复盘】HashMap篇——持续更新中
  • 【SpringBoot框架篇】32.基于注解+redis实现表单防重复提交