zoukankan      html  css  js  c++  java
  • wait()和notify()的理解与使用

    void notify() 
    Wakes up a single thread that is waiting on this object’s monitor. 
    译:唤醒在此对象监视器上等待的单个线程
    
    void notifyAll() 
    Wakes up all threads that are waiting on this object’s monitor. 
    译:唤醒在此对象监视器上等待的所有线程
    
    void wait( ) 
    Causes the current thread to wait until another thread invokes the notify() method or the notifyAll( ) method for this object. 
    译:导致当前的线程等待,直到其他线程调用此对象的notify( ) 方法或 notifyAll( ) 方法
    
    void wait(long timeout) 
    Causes the current thread to wait until either another thread invokes the notify( ) method or the notifyAll( ) method for this object, or a specified amount of time has elapsed. 
    译:导致当前的线程等待,直到其他线程调用此对象的notify() 方法或 notifyAll() 方法,或者指定的时间过完。
    
    void wait(long timeout, int nanos) 
    Causes the current thread to wait until another thread invokes the notify( ) method or the notifyAll( ) method for this object, or some other thread interrupts the current thread, or a certain amount of real time has elapsed. 
    译:导致当前的线程等待,直到其他线程调用此对象的notify( ) 方法或 notifyAll( ) 方法,或者其他线程打断了当前线程,或者指定的时间过完。

    上面是官方文档的简介,下面我们根据官方文档总结一下:

    • wait( ),notify( ),notifyAll( )都不属于Thread类,而是属于Object基础类,也就是每个对象都有wait( ),notify( ),notifyAll( ) 的功能,因为每个对象都有锁,锁是每个对象的基础,当然操作锁的方法也是最基础了。

    • 当需要调用以上的方法的时候,一定要对竞争资源进行加锁,如果不加锁的话,则会报 IllegalMonitorStateException 异常

    • 当想要调用wait( )进行线程等待时,必须要取得这个锁对象的控制权(对象监视器),一般是放到synchronized(obj)代码中。

    • while循环里而不是if语句下使用wait,这样,会在线程暂停恢复后都检查wait的条件,并在条件实际上并未改变的情况下处理唤醒通知

    • 调用obj.wait( )释放了obj的锁,否则其他线程也无法获得obj的锁,也就无法在synchronized(obj){ obj.notify() } 代码段内唤醒A。

    • notify( )方法只会通知等待队列中的第一个相关线程(不会通知优先级比较高的线程)

    • notifyAll( )通知所有等待该竞争资源的线程(也不会按照线程的优先级来执行)

    • 假设有三个线程执行了obj.wait( ),那么obj.notifyAll( )则能全部唤醒tread1,thread2,thread3,但是要继续执行obj.wait()的下一条语句,必须获得obj锁,因此,tread1,thread2,thread3只有一个有机会获得锁继续执行,例如tread1,其余的需要等待thread1释放obj锁之后才能继续执行。

    • 当调用obj.notify/notifyAll后,调用线程依旧持有obj锁,因此,thread1,thread2,thread3虽被唤醒,但是仍无法获得obj锁。直到调用线程退出synchronized块,释放obj锁后,thread1,thread2,thread3中的一个才有机会获得锁继续执行。

    测试用例:

     1 package test;
     2 
     3 /**
     4  * @author zsh
     5  * @company wlgzs
     6  * @create 2019-02-25 9:02
     7  * @Describe 多线程方法wait() and notify() 方法测试
     8  */
     9 public class WaitNotifyTest {
    10 
    11     // 在多线程间共享的对象上使用wait
    12     private String[] shareObj = {"true"};
    13 
    14     //线程等待
    15     class ThreadWait extends Thread{
    16 
    17         public ThreadWait(String name){
    18             super(name);
    19         }
    20 
    21         @Override
    22         public void run() {
    23             synchronized (shareObj){
    24                 while ("true".equals(shareObj[0])){
    25                     System.out.println("线程"+this.getName()+"开始等待");
    26                     long startTime = System.currentTimeMillis();
    27                     try {
    28                         shareObj.wait();
    29                     } catch (InterruptedException e) {
    30                         e.printStackTrace();
    31                     }
    32                     long endTime = System.currentTimeMillis();
    33                     System.out.println("线程"+this.getName()+"等待的时间为"+
    34                             (endTime - startTime));
    35                 }
    36             }
    37             System.out.println("线程" + this.getName() + "等待结束");
    38         }
    39     }
    40 
    41     //线程唤醒
    42     class ThreadNotify extends Thread{
    43 
    44         public ThreadNotify(String name){
    45             super(name);
    46         }
    47 
    48         @Override
    49         public void run() {
    50             try {
    51                 // 给等待线程等待时间
    52                 sleep(3000);
    53             } catch (InterruptedException e) {
    54                 e.printStackTrace();
    55             }
    56             synchronized (shareObj){
    57                 System.out.println("线程" + this.getName() + "开始准备通知");
    58                 shareObj[0] = "false";
    59                 shareObj.notifyAll();
    60                 System.out.println("线程" + this.getName() + "通知结束");
    61             }
    62             System.out.println("线程" + this.getName() + "运行结束");
    63         }
    64     }
    65 
    66     public static void main(String[] args) {
    67         WaitNotifyTest waitNotifyTest = new WaitNotifyTest();
    68         ThreadWait threadWait1 = waitNotifyTest.new ThreadWait("wait thread1");
    69         /**
    70          * 优先级   : 只能反映线程的 重要程度 或者是 紧急程度 , 不能决定 是否一定先执行
    71          * setPriority()
    72          * 1~10   1最低  10最高    5是默认值
    73          */
    74         threadWait1.setPriority(2);
    75         ThreadWait threadWait2 = waitNotifyTest.new ThreadWait("wait thread2");
    76         threadWait2.setPriority(3);
    77         ThreadWait threadWait3 = waitNotifyTest.new ThreadWait("wait thread3");
    78         threadWait3.setPriority(4);
    79 
    80         ThreadNotify threadNotify = waitNotifyTest.new ThreadNotify("notify thread");
    81 
    82         threadNotify.start();
    83         threadWait1.start();
    84         threadWait2.start();
    85         threadWait3.start();
    86     }
    87 
    88 
    89 }
  • 相关阅读:
    【Android Developers Training】 73. 布局变化的动画
    【Android Developers Training】 72. 缩放一个视图
    【Android Developers Training】 71. 显示翻牌动画
    svn更改地址怎么办
    python学习手册
    failed to bind pixmap to texture
    Ubuntu 12.04安装Google Chrome
    svn update 时总是提示 Password for '默认密钥' GNOME keyring: 输入密码
    重设SVN 的GNOME keyring [(null)] 的密码
    Nginx + uWSGI + web.py 搭建示例
  • 原文地址:https://www.cnblogs.com/zsh-blogs/p/10429184.html
Copyright © 2011-2022 走看看