java 多线程编程之synchronized的wait-notify机制

为什么要使用wait-notify?

为了避免处于blocked状态下的线程对监视器锁的竞争;
而竞争是会消耗计算机资源的

正确使用wait-notify

  • wait、notify/notifyAll方法一定要写在synchronized里面。wait、notify/notifyAll的作用是为了避免轮询带来的性能损失,而产生轮询的条件是多个线程对同一个资源进行操作。所以必须先获得监视器锁

  • wait、notify/notifyAll方法定义在Object类里面。wait、notify/notifyAll必须写在synchronized里面,而synchronized的监视器锁可以是任意对象,所以wait、notify/notifyAll方法定义在Object类里面。

  • 调用wait、notify/notifyAll方法的对象,必须和synchronized()的监视器锁一致

  • wait()、notify/notifyAll() 方法是Object的本地final方法,无法被重写。

  • 重要在调用wait()的时候,线程自动释放其占有的监视器锁,同时不会去申锁(不会参与锁的竞争)。当线程被唤醒(notify)的时候,它才再次获得了去竞争监视器锁的权利。如果竞争到了锁,程序会从wait()方法处往下继续执行!
    当线程执行wait()方法时候,会立即释放当前的锁,然后让出CPU,进入等待状态。Runnbel==>waiting

  • 重要 只有当 notify/notifyAll() 被执行时候,才会唤醒一个或多个正处于等待状态的线程,然后继续往下执行,直到执行完synchronized 代码块的代码或是中途遇到wait() ,再次释放锁。
    notify/notifyAll() 的执行只是唤醒沉睡的线程,而不会立即释放锁,锁的释放要看代码块的具体执行情况(一般来说,退出临界区就是释放锁了)。所以在编程中,尽量在使用了notify/notifyAll() 后立即退出临界区,以唤醒其他线程 。

    notify()只是允许调用了wait()方法的线程继续参与锁的竞争,而不会让它马上获得监视器锁,只是告诉它此时可以参与锁的竞争了(参与轮询)。同样,此时占有监视器锁的线程不会立即释放锁,必须等到同步代码块执行完毕才会释放。waiting==>blocked

wait

Object.wait方法将释放当前线程所持有的Object对象监视器锁,而不是当前线程释放所有持有的锁。因此在synchronized嵌套使用的时候就要注意并不是调用了某个Object的wait方法导致释放所有的锁

notify和notifyAll的区别

notify 随机唤醒在监视器对象上等待的单个线程,此时调用该方法的代码继续执行。
notifyAll 唤醒在监视器对象上等待的所有线程,此时调用该方法的代码继续执行。

notify 和wait 的顺序不能错

如果A线程先执行notify方法,B线程后执行wait方法,那么B线程是无法被唤醒的。B线程会一直出于waiting状态。

可以看代码


    public static void main(String[] args) throws InterruptedException {

        new Thread(new Runnable() {
            @SneakyThrows
            @Override
            public void run() {

                synchronized (TestThread.class) {
                    System.out.println("A线程开始执行notify");
                    TestThread.class.notify();
                }
            }
        },"A").start();

        Thread.sleep(1000*1);

        new Thread(new Runnable() {
            @SneakyThrows
            @Override
            public void run() {
                synchronized (TestThread.class) {
                    System.out.println("B线程将一直等待下去....");
                    TestThread.class.wait();

                }
            }
        },"B").start();


    }

使用wait、notify机制,线程状态的变化情况

class TestThread {

    private static Logger logger = Logger.getLogger(TestThread.class);

    private static Thread t6 = new Thread(new Runnable() {
        @Override
        public void run() {

            synchronized (TestThread.class) {
                System.out.println("t6: t6线程获得监视器锁进入临界区");
                System.out.println("t6: t6线程调用wait()方法释放监视器锁,进入等待队列");
                try {
                    TestThread.class.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("t6: t6线程被通知激活,从wait()方法后继续执行");
                System.out.println("t6: 打印t7此时状态"+t7.getName()+"==>"+t7.getState());

            }


        }
    }, "t6");

    private static Thread t7 =  new Thread(new Runnable() {
        @Override
        public void run() {
            synchronized (TestThread.class){
                System.out.println("t7: t7线程获得监视器锁进入临界区");
                System.out.println("t7: t7线程工作3秒");
                try {
                    Thread.sleep(1000*3);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("t7: t7线程工作完毕,通知t6线程可以参与锁的竞争了");
                System.out.println("t7: notify前打印"+t6.getName()+"==>"+t6.getState());
                TestThread.class.notify();
                System.out.println("t7: notify后打印"+t6.getName()+"==>"+t6.getState());
            }
            //死循环打印t6线程的状态
            while (true){
                logger.debug("t7: t7退出临界区后打印"+t6.getName()+"==>"+t6.getState());
            }


        }
    },"t7");



    public static void main(String[] args) throws InterruptedException {


        t6.start();
        //main线程睡眠1秒,确保t6线程先执行
        Thread.sleep(1000);
        t7.start();


    }
}

t6: t6线程获得监视器锁进入临界区
t6: t6线程调用wait()方法释放监视器锁,进入等待队列
t7: t7线程获得监视器锁进入临界区
t7: t7线程工作3秒
t7: t7线程工作完毕,通知t6线程可以参与锁的竞争了
t7: notify前打印t6==>WAITING
t7: notify后打印t6==>BLOCKED
t6: t6线程被通知激活,从wait()方法后继续执行
t6: 打印t7此时状态t7==>RUNNABLE
[DEBUG] 2020-02-11 14:16:42,966 method:test.TestThread$2.run(A.java:248)
t7: t7退出临界区后打印t6==>RUNNABLE

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 194,088评论 5 459
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 81,715评论 2 371
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 141,361评论 0 319
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 52,099评论 1 263
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 60,987评论 4 355
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 46,063评论 1 272
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 36,486评论 3 381
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 35,175评论 0 253
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 39,440评论 1 290
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 34,518评论 2 309
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 36,305评论 1 326
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 32,190评论 3 312
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 37,550评论 3 298
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 28,880评论 0 17
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,152评论 1 250
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 41,451评论 2 341
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 40,637评论 2 335

推荐阅读更多精彩内容