Java多线程之《等待/通知机制》-java教程-PHP中文网

Java多线程之《等待/通知机制》

无忌哥哥

发布： 2018-07-23 11:07:50

原创

2256人浏览过

经典范式：

等待方遵循如下原则：

1、获取对象的锁。
2、如果条件不满足，那么调用对象的wait()方法，被通知后仍要检查条件。
3、条件满足则执行对应的逻辑任务。
伪代码如下：

synchronized(对象) { 
        while(条件不满足) { 
            对象.wait(); 
        } 
        完成任务逻辑 
     }

登录后复制

通知方遵循如下原则：
1、获得对象的锁。
2、改变条件。
3、通知所有等待在对象上的线程。
伪代码如下：

synchronized(对象) { 

        改变对象 

        对象.notifyAll(); 

    }

登录后复制

示例代码：

CmsEasy易通企业网站系统

易通企业网站系统别名CmsEasy 是国内唯一免费微信+手机端+微网站+手机短信+在线销售+多语言网站组合的企业营销管理平台，易通企业网站系统也称易通企业网站程序，是易通公司开发中国首套免费提供企业网站模板的营销型企业网站管理系统，系统前台生成html、完全符合SEO、同时有在线客服、潜在客户跟踪、便捷企业网站模板制作、搜索引擎推广等功能的企业网站系统。

154

查看详情

import java.text.SimpleDateFormat;import java.util.Date;/**
 * 线程等待/通知机制
 * Created by peng on 2018/7/22.
 */public class WaitNotify {

    private static boolean flag = true;    private static Object lock = new Object();    public static void main(String[] args) {
        Thread waitThread = new Thread(new Wait(), "WaitThread");
        waitThread.start();
        SleepUtils.second(1);

        Thread notifyThread = new Thread(new Notify(), "NotifyThread");
        notifyThread.start();
    }    private static class Wait implements Runnable {
        @Override
        public void run() {            // 加锁，拥有lock的Monitor
            synchronized (lock) {                // 当条件不满足时，继续wait，同时释放了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) {
                        e.printStackTrace();
                    }
                }                // 条件满足时，完成工作
                System.out.println(Thread.currentThread() + " flag is false. running @ "
                        + new SimpleDateFormat("HH:mm:ss").format(new Date()));
            }
        }
    }    
    private static class Notify implements Runnable {
        @Override
        public void run() {            // 加锁，拥有lock的Monitor
            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);
            }
        }
    }
}

登录后复制

以上就是Java多线程之《等待/通知机制》的详细内容，更多请关注php中文网其它相关文章！