Java Condition

Posted 2020-10-05

在Condition中，用await()替换wait()，用signal()替换notify()，用signalAll()替换notifyAll()，传统线程的通信方式，Condition都可以实现，这里注意，Condition是被绑定到Lock上的，要创建一个Lock的Condition必须用newCondition()方法。

 

class BoundedBuffer {  

final Lock lock = new ReentrantLock();//锁对象  

final Condition notFull  = lock.newCondition();//写线程条件   

final Condition notEmpty = lock.newCondition();//读线程条件   

final Object[] items = new Object[100];//缓存队列  

int putptr/*写索引*/, takeptr/*读索引*/, count/*队列中存在的数据个数*/;  

publicvoid put(Object x) throws InterruptedException {  

lock.lock();  

try {  

while (count == items.length)//如果队列满了   

notFull.await();//阻塞写线程  

items[putptr] = x;//赋值   

if (++putptr == items.length) putptr = 0;//如果写索引写到队列的最后一个位置了，那么置为0  

++count;//个数++  

notEmpty.signal();//唤醒读线程  

} finally {  

lock.unlock();  

}  

}  

public Object take() throws InterruptedException {  

lock.lock();  

try {  

while (count == 0)//如果队列为空  

notEmpty.await();//阻塞读线程  

Object x = items[takeptr];//取值   

if (++takeptr == items.length) takeptr = 0;//如果读索引读到队列的最后一个位置了，那么置为0  

--count;//个数--  

notFull.signal();//唤醒写线程  

return x;  

} finally {  

lock.unlock();  

}  

}   

}