码迷,mamicode.com
首页 > 编程语言 > 详细

java线程的等待、通知机制【读书笔记】

时间:2016-06-18 15:29:10      阅读:151      评论:0      收藏:0      [点我收藏+]

标签:

代码示例:

package com.baidu.nuomi.concurrent;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;

/**
 * Created by sonofelice on 16/6/18.
 */
public class WaitNotify {
    static boolean flag = true;
    static Object lock = new Object();

    public static void main(String[] args) throws Exception{
        Thread waitThread = new Thread(new Wait(),"WaitThread");
        waitThread.start();
        TimeUnit.SECONDS.sleep(1);
        Thread notifyThread = new Thread(new Notify(),"NotifyThread");
        notifyThread.start();
        
    }
    static class Wait implements Runnable{
        @Override
        public void run() {
            synchronized (lock){
                while (flag){
                    try {
                        System.out.println(Thread.currentThread() + " flag is true. wait @ "
                                + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                        lock.wait();
                    }catch (InterruptedException e){
                    }
                }
                System.out.println(Thread.currentThread() + "flag is false. running @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
            }
        }
    }
    static class Notify implements Runnable{
        @Override
        public void run() {
            synchronized (lock){
                System.out.println(Thread.currentThread() + "hold lock. notify @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                lock.notifyAll();
                flag = false;
                SleepUtils.second(5);
            }
            synchronized (lock){
                System.out.println(Thread.currentThread() + "hold lock again. sleep @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
                SleepUtils.second(5);
            }
        }
    }
}

输出如下:

Thread[WaitThread,5,main] flag is true. wait @ 12:21:04
Thread[NotifyThread,5,main]hold lock. notify @ 12:21:05
Thread[NotifyThread,5,main]hold lock again. sleep @ 12:21:10
Thread[WaitThread,5,main]flag is false. running @ 12:21:15

Process finished with exit code 0

调用wait() notify()  notifyAll()方法时需要注意的细节:

1)使用wait() notify()  notifyAll() 时需要先对调用对象加锁;

2)调用wait()方法后,线程状态由RUNNING 变为WAITING,并将当前线程放置到对象的等待队列。

3)notify()或notifyAll() 方法调用后,等待线程依旧不会从wait返回,需要调用notify()或notifyAll()的线程释放锁之后,等待线程才有机会从wait()返回。

4)notify()方法将等待队列中的一个等待线程从等待队列中移到同步队列中,而notifyAll()方法则是将等待队列中的所有的线程全部移到同步队列,被移动的线程状态由WAITING变为BLOCKED。

5)从wait()方法返回的前提是获得了调用对象的锁。

从上面的细节可以看出,等待/通知机制依托于同步机制,其目的就是确保等待线程从wait()方法返回时能够感知到通知线程对变量做出的修改。

 

从而抽象出等待/通知的经典范式:

等待方:

1)获取对象锁;

2)如果条件不满足,那么调用对象的wait()方法,被通知后仍要检查条件。

3)条件满足则执行对应的逻辑。

对应的伪代码如下:

synchronized(对象){

while(条件不满足){

 Object.wait();

}

逻辑处理

}

 

通知方:

1)获得对象的锁;

2)改变条件;

3)通知所有等待在对象上的线程。

对应的伪代码如下:

synchronized(对象){

  改变条件

  对象.notifyAll();

}

 

java线程的等待、通知机制【读书笔记】

标签:

原文地址:http://www.cnblogs.com/sonofelice/p/5596159.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!