上一次我们介绍了ReentrantLock和Synchronized的异同,这次我们来讲讲concurrent包下面的另外一个类,Condition。 Java的 java.util.concurrent 包提供了很多处理并发场景的类,Condition 就是其中一个。
我们花三分钟来了解Condition的作用吧~
现在有个队列,线程A和线程B同时往里面写数据。 A从1写到3,B从4写到6,再交给A从7写到10,这样的场景我们要怎么处理问题呢?
首先想到的是并发加锁处理,然后就是我们要介绍的Condition了!
//初始化锁
final Lock lock = new ReentrantLock();
//第一个条件当A写到3
final Condition reachThreeCondition = lock.newCondition();
//第二个条件当B写到6
final Condition reachSixCondition = lock.newCondition();
获取Condition对象的方法很简单,对锁进行newCondition()操作就可以。 我们直接以 ThreadA 举例,B的逻辑也是一样的。
Thread threadA = new Thread(new Runnable() {
@Override
public void run() {
//需要先获得锁
lock.lock();
try {
System.out.println("threadA start write");
//A线程先写前3个数
...
//输出到3时要signal,告诉B线程可以开始了
reachThreeCondition.signal(); <====
} finally {
lock.unlock();
}
lock.lock();
try {
//等待B写到6的条件
reachSixCondition.await(); <====
System.out.println("threadA start write");
//写剩余数字
...
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
});
B线程
Thread threadB = new Thread(new Runnable() {
@Override
public void run() {
try {
lock.lock();
while (num.value <= 3) {
//等待3写完的信号
reachThreeCondition.await(); <====
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
try {
lock.lock();
//已经收到信号,开始写4,5,6
System.out.println("threadB start write");
...
//4,5,6写完,告诉A线程
reachSixCondition.signal(); <====
} finally {
lock.unlock();
}
}
});
代码很简单, · 当我们需要某个条件满足才继续往下执行时,调用Condition的await()方法, 此时线程会挂起,同时释放锁; · 其他并发线程完成条件后调用Condition的singnal()方法, 其他等待这个Condition的线程则会获取锁并继续往下执行。
当处理并发场景且需要等待某种条件时,一般都会将Condition对象作为成员变量。当调用await()方法后,当前线程会释放锁并在此等待,而其他线程调用Condition对象的signal()方法,通知当前线程后,当前线程才从await()方法返回,并且在返回前已经获取了锁。
聪明的你肯定意识到Condition和BlockingQueue会有某种联系。是的阻塞队列BlockingQueue的原理就是基于Condition实现的
我们下一次继续介绍BlockingQueue吧! 欢迎关注订阅!