为了更好的支持多线程之间的协作,JDK 提供了三个重要的本地方法
- //调用某个对象的wait()方法能让当前线程阻塞,并且当前线程必须拥有此对象的锁.
- public final void wait() throws InterruptedException {
- wait(0);
- }
- //调用某个对象的notify()方法能够唤醒一个正在等待这个对象的锁的线程,如果有多个线程都在等待这个对象的锁,则只能唤醒其中一个线程
- public final native void notify();
- //notifyAll()方法能够唤醒所有正在等待这个对象锁的线程;
- public final native void notifyAll();
如图:当一个拥有 Object 锁的线程调用 wait() 方法时,就会使当前线程加入 object.wait 等待队列中,并且释放当前占用的 Object 锁,这样其他线程就有机会获取这个 Object 锁,获得 Object 锁的线程调用 notify() 方法,就能在 Object.wait 等待队列中随机唤醒一个线程(该唤醒是随机的与加入的顺序无关,优先级高的被唤醒概率会高),若果调用 notifyAll()方法就唤醒全部的线程。注意: 调用 notify() 方法后并不会立即释放 object 锁,会等待该线程执行完毕后释放 Object 锁。
代码:
- public class WaitTest {
- private static Object object = new Object();
- public static void main(String[] args) {
- Thread thread = new Thread() {@Override public void run() {
- synchronized(object) {
- System.out.println(System.currentTimeMillis() + ":" + Thread.currentThread().getName() + "进入启动");
- try {
- object.wait(); //使当前线程进入等待(进入Object.wait队列)并释放对象锁
- } catch(InterruptedException e) {
- e.printStackTrace();
- }
- System.out.println(System.currentTimeMillis() + ":" + Thread.currentThread().getName() + "线程执行结束");
- }
- }
- };
- thread.start();
- Thread thread_2 = new Thread() {@Override public void run() {
- synchronized(object) {
- System.out.println(System.currentTimeMillis() + ":" + Thread.currentThread().getName() + "进入启动");
- try {
- object.notify(); //随机在Object.waitd队列中唤醒一个正在等待该对象锁的线程
- System.out.println(System.currentTimeMillis() + ":" + Thread.currentThread().getName() + "唤醒一个等待的线程");
- Thread.sleep(10000);
- } catch(InterruptedException e) {
- e.printStackTrace();
- }
- }
- }
- };
- thread_2.start();
- }
- }
执行结果:
- 1473306408730 : Thread - 0进入启动1473306408731 : Thread - 1进入启动1473306408731 : Thread - 1唤醒一个等待的线程1473306418731 : Thread - 0线程执行结束
从时间戳中可以看出 Thread-1 在通知 Thread-0 继续执行后,Thread-0 并未立即执行,而是等待 Thread-1 释放 Object 锁,在重新获得 Object 锁后,才能继续执行。(最后两个时间戳相减刚好是 10 秒)
来源: http://www.cnblogs.com/jalja/p/5852556.html