当前位置:编程学习 > JAVA >>

BoundedBuffer 之我见

看到java.util.concurrent.locks.*的Condition里面给出了一个例子,是BoundedBuffer,这个例子倒是不是很难,可是说是很经典的一个应用。

[java] 
class BoundedBuffer { 
        final Lock lock = new ReentrantLock(); 
        final Condition notEmpty = lock.newCondition(); 
        final Condition notFull = lock.newCondition(); 
 
        final int MAX_SIZE = 5; 
        List<Object> list = new ArrayList<Object>(); 
        int count = 0; 
 
        public void put(Object obj) throws InterruptedException { 
            lock.lock(); 
            try { 
                while (count == MAX_SIZE) { 
                    notFull.await(); 
                } 
                list.add(obj); 
                count++; 
                System.out.println("call: notEmpty.signal()"); 
                notEmpty.signal(); 
            } finally { 
                lock.unlock(); 
            } 
        } 
 
        public Object take() throws InterruptedException { 
            lock.lock(); 
            try { 
                while (count == 0) { 
                    notEmpty.await(); 
                } 
                Object obj = list.remove(0); 
                count --; 
                System.out.println("call: notFull.signal()"); 
                notFull.signal(); 
                return obj; 
            } finally { 
                lock.unlock(); 
            } 
        } 
    } 


对于Java变量的命名,我相信Sun公司的人一般不会选择没有含义的名称,可是在这里 一个notFull和notEmpty让我很是纠结notFull.await()是什么意识?notEmpty.await()以及相应的signal()是什么意思,当然代码是最好的倒是,但要是从意义上来理解就更好了。

不难看出,notEmpty表示的是缓存非空,那么notEmpty.await()表示的意识就是缓存非空这个条件为假(同意是‘现在缓存是空的!’所以,老大给我停下来),相应的notEmpty.signal() 就表示缓存非空为真,然后就祈祷:神啊!(在这里的神当然指的是系统调度了)我已经准备好了,可以开始了。同理也能够理解notFull了。

 


作者:acnt3w
补充:软件开发 , Java ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,