Condition实现等待/通知模式

古城微笑少年丶 2023-03-01 13:58 36阅读 0赞

## Condition实现等待/通知模式 ##

`Condition`接口提供了类似`Object`的监视器方法，与`Lock`配合可以实现等待/通知模式，但是这两者在使用方式以及功能特性上还是有差别的。`Object`和`Condition`接口的一些对比。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]

**Condition主要的几个方法：**

*  **void await()**：当前线程进入等待状态，如果其他线程调用`condition`的`signal`或者`signalAll`方法并且当前线程获取`Lock`从`await`方法返回，如果在等待状态中被中断会抛出被中断异常；
 *  **void signal()**：唤醒一个等待在`condition`上的线程，将该线程从等待队列中转移到同步队列中，如果在同步队列中能够竞争到`Lock`则可以从等待方法中返回。
 *  **void signalAll()**：与1的区别在于能够唤醒所有等待在`condition`上的线程

/** * 面试题：写一个固定容量同步容器，拥有put和get方法，以及getCount方法， * 能够支持2个生产者线程以及10个消费者线程的阻塞调用 * * 使用wait和notify/notifyAll来实现 * * 使用Lock和Condition来实现（**注意：不要将获取锁的过程放在try块中，因为如果在获取锁时发生了异常，异常抛出的同时，也会导致锁无故释放**） * 对比两种方式，Condition的方式可以更加精确的指定哪些线程被唤醒 */
    import java.util.LinkedList;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    public class conditionDemo<T> { 
        final private LinkedList<T> lists = new LinkedList<>();
        final private int MAX = 10; //最多10个元素
        private int count = 0;
    
        private Lock lock = new ReentrantLock();
        private Condition producer = lock.newCondition();
        private Condition consumer = lock.newCondition();
    
        public void put(T t) { 
            try { 
                lock.lock();
                while(lists.size() == MAX) {  //想想为什么用while而不是用if？
                    producer.await();
                }
    
                lists.add(t);
                ++count;
                consumer.signalAll(); //通知消费者线程进行消费
                System.out.println("通知消费者线程进行消费");
            } catch (InterruptedException e) { 
                e.printStackTrace();
            } finally { 
                lock.unlock();
            }
        }
    
        public T get() { 
            T t = null;
            try { 
                lock.lock();
                while(lists.size() == 0) { 
                    consumer.await();
                }
                t = lists.removeFirst();
                count --;
                producer.signalAll(); //通知生产者进行生产
                System.out.println("通知生产者进行生产");
            } catch (InterruptedException e) { 
                e.printStackTrace();
            } finally { 
                lock.unlock();
            }
            return t;
        }
    
        public static void main(String[] args) { 
            conditionDemo<String> c = new conditionDemo<>();
            //启动消费者线程
            for(int i=0; i<10; i++) { 
                new Thread(()->{ 
                    for(int j=0; j<5; j++) System.out.println(c.get());
                }, "c" + i).start();
            }
    
            try { 
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) { 
                e.printStackTrace();
            }
    
            //启动生产者线程
            for(int i=0; i<2; i++) { 
                new Thread(()->{ 
                    for(int j=0; j<15; j++) c.put(Thread.currentThread().getName() + " " + j);
                }, "p" + i).start();
            }
        }
    }

**运行结果：**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 2]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center]: /images/20230208/5f56bbb4209c40fc98ce99bbd9aeba65.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 1]: https://img-blog.csdnimg.cn/20210225214108943.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA==,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA_size_16_color_FFFFFF_t_70_pic_center 2]: https://img-blog.csdnimg.cn/20200812232009157.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MDk5MDgxOA==,size_16,color_FFFFFF,t_70#pic_center