并发编程 AQS 思想之Condition 接口的标准使用（十三）

电玩女神 2022-12-28 00:50 220阅读 0赞

今天我们分析并发编程原子操作 AQS 思想之Condition 接口 的标准使用：

任意一个 Java 对象，都拥有一组监视器方法（定义在 java.lang.Object 上）， 主要包括 wait()、wait(long timeout)、notify()以及 notifyAll()方法，这些方法与

synchronized  同步关键字配合，可以实现等待 / 通知模式。 Condition  接口也提供 了类似 Object  的监视器方法，与  Lock  配合可以实现等待 / 通知模式。

***1、Condition***  ***常用方法：***

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70][]

***2、Condition***  ***使用范式：***

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1][]

***3、Condition***  ***使用 配合Lock接口：***

public class ExpressCond {
        public final static String CITY = "ShangHai";
        private int km;/*快递运输里程数*/
        private String site;/*快递到达地点*/
    
        private Lock kmLock = new ReentrantLock();//里程锁
        private Lock siteLock = new ReentrantLock();//地点锁，可以和里程锁用同意把锁。
    
        private Condition kmCond = kmLock.newCondition();//控制里程数的
        private Condition siteCond = siteLock.newCondition();//控制地点的
        public ExpressCond() {
        }
        public ExpressCond(int km, String site) {
            this.km = km;
            this.site = site;
        }
        /* 变化公里数，然后通知处于wait状态并需要处理公里数的线程进行业务处理*/
        public void changeKm(){
            kmLock.lock();
            try{
                this.km = 101;
                kmCond.signal();
                //kmCond.signalAll();
            }finally {
                kmLock.unlock();
            }  
        }
    
        /* 变化地点，然后通知处于wait状态并需要处理地点的线程进行业务处理*/
        public  void changeSite(){
        	siteLock.lock();
        	try {
        		this.site = "BeiJing";
        		siteCond.signal();//通知其他在锁上等待的线程
        	}finally {
        		siteLock.unlock();
        	}
        }
    
        /*当快递的里程数大于100时更新数据库*/
        public void waitKm(){
            kmLock.lock();
            try{
                while(this.km<100){
                    try {
                        kmCond.await();
                        System.out.println("Check Site thread["
                                +Thread.currentThread().getId()
                                +"] is be notified");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }finally {
                kmLock.unlock();
            }
            System.out.println("the Km is "+this.km+",I will change db");
        }
    
        /*当快递到达目的地时通知用户*/
        public void waitSite(){
        	siteLock.lock();
        	try {
            	while(this.site.equals(CITY)) {
            		try {
        				siteCond.await();//当前线程进行等待
        				System.out.println("check Site thread["+Thread.currentThread().getName()
        						+"] is be notify");
        			} catch (InterruptedException e) {
        				// TODO Auto-generated catch block
        				e.printStackTrace();
        			}
            	}
        	}finally {
        		siteLock.unlock();
        	}
            System.out.println("the site is "+this.site+",I will call user");
        }
    }

测试main方法：

public class TestCond {
        private static ExpressCond express = new ExpressCond(0,ExpressCond.CITY);
        /*检查里程数变化的线程,不满足条件，线程一直等待*/
        private static class CheckKm extends Thread{
            @Override
            public void run() {
            	express.waitKm();
            }
        }
    
        /*检查地点变化的线程,不满足条件，线程一直等待*/
        private static class CheckSite extends Thread{
            @Override
            public void run() {
            	express.waitSite();
            }
        }
        public static void main(String[] args) throws InterruptedException {
            for(int i=0;i<3;i++){
                new CheckSite().start();
            }
            for(int i=0;i<3;i++){
                new CheckKm().start();
            }
            Thread.sleep(1000);
            express.changeKm();//快递里程变化
            express.changeSite();//快递地点变化
        }
    }

执行结果：

![20201213201856677.png][]

**4、了解**  **LockSupport：**

LockSupport  定义了一组的公共静态方法，这些方法提供了最基本的线程阻 塞和唤醒功能，而 LockSupport  也成为构建同步组件的基础工具。 LockSupport  定义了一组以  park  开头的方法用来阻塞当前线程，以及 unpark(Thread thread)方法来唤醒一个被阻塞的线程。 LockSupport  增加了 park(Object blocker)、 parkNanos(Object blocker,long nanos) 和  parkUntil(Object blocker,long deadline)3 个方法，用于实现阻塞当前线程的功能，其中参数  blocker 是用来标识当前线程在等待的对象（以下称为阻塞对象），该对象主要用于问题 排查和系统监控，此类用的不多，方法如下图：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2][]

有用到时可以认真测试，今天分享到此结束。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70]: /images/20221120/ab4abea346a24f5abf099254572f302b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 1]: /images/20221120/b6370fe699b04efab5286d661aced3e8.png
[20201213201856677.png]: https://img-blog.csdnimg.cn/20201213201856677.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201213203322164.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L25hbmRhbzE1OA==,size_16,color_FFFFFF,t_70