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 ,