- WHO ?
我是一个普通当程序员，目前正在学习java并发编程，为学习netty做准备。 - WHAT & WHEN ?
主题呢，和标题一样理解一下Java中当Lock & Condition - Why ?
写这篇文章，主要是讲解一下Lock和Condition。同时呢，给一些和我一样在学习java并发编程当同学提供一些参考。我在学习Lock和Condition的时候，觉得很迷茫。看别人的博客什么的都能看的懂，但是自己写的时候就各种错误。 - How ?
直接步入正题:
Lock顾名思义就是锁的意思。
Condition翻译过来就是"条件"的意思。那么Condition是谁的条件呢?看一下Condition是怎么创建的就知道了。
Lock lock = new ReentrantLock();
Conditon notFull = lock.newCondition();
从上面的代码,我们可以一眼就看出所谓的"条件",就是Lock的条件。你可以理解为Lock的成员变量（你可以姑且这么认为）。有了以上基础以后，我们再来看一下下面这段代码：
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class MyBlockedQueue<T> {
final Lock lock = new ReentrantLock();
final Condition notFull = lock.newCondition();
final Condition notEmpty = lock.newCondition();
private Queue queue = new ArrayBlockingQueue(5);
void enq(T e){
lock.lock();
try {
while (queue.size() == 5){
notFull.await();
}
// TODO: 2019/8/26 do something for enque
notEmpty.signal();
}catch (InterruptedException ex) {
ex.printStackTrace();
} finally {
lock.unlock();
}
}
void denq(){
lock.lock();
try {
while (!queue.isEmpty()){
notEmpty.await();
}
// TODO: 2019/8/26 do something for denque
notFull.signal();
}catch (InterruptedException ex){
ex.printStackTrace();
} finally {
lock.unlock();
}
}
}
代码理解:
上面的代码定义了enq和denq俩个方法，这俩个方法是互斥的，所以声明了一个变量lock。lock是一个可重入锁（关于可重入锁，后续会讲到详细当内容）。lock锁有俩个条件（成员变量）notFull和notEmpty。
线程A执行enq方法时,先获取锁,然后判断队列是否是满的,如果是满的,则等待deq方法被执行；随后，当线程A执行denq()方法时,获取锁,然后发现队列并不是空的，可以执行deq业务逻辑，然后唤起其他等待notFull的线程。这个时候线程A的enq方法发现，queue.size()==5的条件不满足了,执行enq业务逻辑。
当其他线程想要同时执行该对象当enq方法时，因为获取不到锁，所以会产生线程阻塞。
- Q&A
Q1:为什么使用await()和signal(),不使用wait()和notify()?
A1:这里涉及到java sdk俩套并发设计。使用Lock和Condition的话只能配套使用await()和signal();wait()和notify()是配合synchronized使用。如果混用，那么你的程序会出各种问题。
有其他问题，可以关注公众号‘麻油地’，留言，我会及时进行回复，解答。
