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 }
  • 相关阅读:
    POJ 2892 Tunnel Warfare(树状数组+二分)
    POJ 2886 Who Gets the Most Candies?(树状数组+二分)
    POJ 2492 A Bug's Life(并查集)
    POJ 1182 食物链(并查集)
    POJ 1703 Find them, Catch them(种类并查集)
    TC SRM 582 DIV 2
    函数
    shell进阶--流程
    计划任务 at,cron
    kill命令
  • 原文地址:https://www.cnblogs.com/zsh-blogs/p/10429184.html
Copyright © 2011-2022 走看看