标签:
Object类中存在wait()和notify(),notifyAll(),即调用这三个方法时必须要Objecy.wait(),Object.notify()。
使用这三个方法的前提是必须获得该对象的锁,即必须在sychronize方法中执行。
wait()的工作过程是:当线程执行object.wait()时,会释放当前object对象的锁,并进入object对象的等待队列。
notify()的运行过程是:当线程执行object.notify()时,会将object的等待队列中一个随机线程唤醒,notifyAll()则是唤醒object等待队列的所有线程。
我们构造一个实例:两个线程对object对象有同步操作,线程1wait()后,线程2notigy()唤醒线程1,并查看线程的执行过程。
/*******************************************************************************
 *                                                                              
 *  COPYRIGHT (C) 2016 Tuniu Limited - ALL RIGHTS RESERVED.                  
 *                                                                                                                                 
 *  Creation Date: 2016年9月27日                                                      
 *                                                                              
 *******************************************************************************/
package thread;
import java.util.concurrent.TimeUnit;
/**
 * @author zhoujie8
 * 
 */
public class TestWaitNofity {
    private final static Object object = new Object();
    public static void main(String[] args) {
        Thread1 t1 = new Thread1();
        Thread2 t2 = new Thread2();
        t1.start();
        t2.start();
    }
    public static class Thread1 extends Thread {
        @Override
        public void run() {
            synchronized (object) {
                System.out.printf("%s %s start\n", System.currentTimeMillis(), Thread.currentThread().getName());
                try {
                    System.out.printf("%s %s wait\n", System.currentTimeMillis(), Thread.currentThread().getName());
                    object.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.printf("%s %s end\n", System.currentTimeMillis(), Thread.currentThread().getName());
            }
        }
    }
    public static class Thread2 extends Thread {
        @Override
        public void run() {
            synchronized (object) {
                System.out.printf("%s %s start\n", System.currentTimeMillis(), Thread.currentThread().getName());
                object.notify();
                System.out.printf("%s %s notify\n", System.currentTimeMillis(), Thread.currentThread().getName());
                try {
                    TimeUnit.SECONDS.sleep(2);
                } catch (InterruptedException ex) {
                    ex.printStackTrace();
                }
            }
        }
    }
}
输出结果为:
1475030841975 Thread-0 start 1475030842000 Thread-0 wait 1475030842000 Thread-1 start 1475030842000 Thread-1 notify 1475030844001 Thread-1 end 1475030844001 Thread-0 wait
可以看出:wait()之后,Thread0释放object的锁,并进入等待队列,thread1获得锁,并且唤醒Thread0。
但是需要注意的是:Thread-1 sleep的2S内并没有释放object的锁,所以Thread-0在2S过后才会被唤醒并获取Object锁继续执行。
标签:
原文地址:http://www.cnblogs.com/jiejiecool/p/5915512.html