ReentrantLock条件变量使多个线程顺序执行
一一哥Sun 人气:0一. 前言
近日一个学生在参加某公司校招面试时，遇到一个多个线程顺序执行的面试题，特意记录下来和大家分享一下，这个题目的具体要求是这样的：
假设有3个线程 a,b,c，要求三个线程一起进入到就绪态，执行时一定 要 按照 a-->b-->c的顺序执行 。即使 a或者b线程进入 到了 阻塞态，也一定 会 按照a-->b-->c的顺序运行线程 。请问该如何保证实现这个需求呢？
二. 解决方案
关于这道题，百度一下网上常见的实现思路，大致有4种解决方案：
通过join()方法使当前线程“阻塞”，等待指定线程执行完毕后继续执行；
通过倒数计时器CountDownLatch实现；
通过创建单一化线程池 newSingleThreadExecutor()实现；
通过ReentrantLock 中的条件变量实现；
今天壹哥先使用ReentrantLock 的条件变量来实现这个题目中的需求。
三. 使用ReentrantLock 条件变量
首先咱们来了解一下，什么是ReentrantLock 条件变量(Condition)。
ReentrantLock 中的条件变量功能，类似于普通 synchronized 的 wait、notify，我们可以使用Reentrantlock 锁，配合 Condition 对象上的 await()和 signal()或 signalAll()方法，来实现线程间协作。与synchronized的wait和notify不同之处在于，ReentrantLock中的条件变量可以有多个，可以实现更精细的控制线程。
Condition中常用的方法API有如下这些：
编辑
ReentrantLock代码实现：
class ShareDataLock{
// 线程执行的条件 1：线程1执行 2：线程2执行 3：线程3执行
int number =1;
// 锁
Lock lock = new ReentrantLock();
// 从锁中获得3个条件变量
Condition condition1 = lock.newCondition();
Condition condition2 = lock.newCondition();
Condition condition3 = lock.newCondition();
// 第一个线程run之后执行的方法
public void f1(){
lock.lock();
try {
// 如果条件值不为1 就挂起等待
while(number!=1){
condition1.await();
}
// 故意阻塞100毫秒，看看其他的线程会不会不再排队
Thread.sleep(100);
System.out.println("------1--------");
// 线程1 执行完毕 把变量设置为2
number = 2;
// 唤醒第2个条件变量
condition2.signal();
} catch (Exception e) {
e.printStackTrace();
} finally {
// 不管抛没抛出异常都要解锁，防止线程死锁
lock.unlock();
}
}
public void f2(){
lock.lock();
try {
while(number!=2){
condition2.await();
}
System.out.println("------2--------");
number = 3;
condition3.signal();
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
public void f3(){
lock.lock();
try {
while(number!=3){
condition3.await();
}
System.out.println("------3--------");
number = 1;
condition1.signal();
} catch (Exception e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}
public class SynchronizedAndReentrantLockDemo {
public static void main(String[] args) {
ShareDataLock shareDataLock = new ShareDataLock();
for (int i = 0; i < 10; i++) {
// 3个线程分别执行1,2,3 3个方法 ，并且同时就绪
new Thread(()->shareDataLock.f1(),"AA").start();
new Thread(()->shareDataLock.f2(),"bb").start();
new Thread(()->shareDataLock.f3(),"cc").start();
}
}
}
代码执行效果如下图：
现在我们就会发现，3个线程已经可以被随意控制了，你会了吗？
四. 后话
如上文所述，让多个线程按顺序执行，网上常见的解决方案有4种。但大家要注意的是，面试官出这个题有一个先决条件，“要让所有的线程同时就绪 ” ，所以我们就可以排除使用join方法和使用单一化线程池的方案了。那么要想实现这个面试题中的需求，比较靠谱的方法只剩下ReentrantLock 中的条件变量和使用倒数计时器CountDownLatch两种方案了 。
今天咱们暂时先介绍条件变量的方法，会在日后的文章中介绍怎样使用CountDownLatch ， 让多个线程有序执行.
加载全部内容