并发编程学习之Condition和顺序访问

一、Condition简介

二、Condition常用API

三、Condition顺序访问案例

一、Condition简介

JUC提供了Lock同步锁可以方便的进行锁操作，但是有时候我们也需要对线程进行条件性的阻塞和唤醒，这时我们就需要结合Condition条件变量来对持有锁的线程进行阻塞和唤醒。

Condition接口，也称为条件队列或条件变量，提供了一种方法，让一个线程暂停执行，直到另一个线程通知某个状态条件，才唤醒其继续执行。

Condition实例本质上绑定到锁，使用其newCondition()方法即可获取特定锁实例的条件实例。Condition一般配合RenentrantLock可重入锁使用，在上一篇的生产者消费者模型中其实我们已经看过Condition的简单使用，下面详细介绍一下Condition接口。

二、Condition常用API

void	await() 导致当前线程等待，直到发出信号或中断它。
boolean	await(long time, TimeUnit unit) 导致当前线程等待，直到发出信号或中断它，或指定的等待时间过期。
long	awaitNanos(long nanosTimeout) 导致当前线程等待，直到发出信号或中断它，或指定的等待时间过期。
void	awaitUninterruptibly() 导致当前线程等待，直到它被通知。
boolean	awaitUntil(Date deadline) 导致当前线程等待，直到发出信号或中断它，或指定的截止日期过期。
void	signal() 唤醒一个正在等待的线程。
void	signalAll() 唤醒所有等待的线程。

以上是Condition接口中常见的一些方法，更加详细的介绍也可以到官网https://docs.oracle.com/javase/8/docs/api/index.html进行了解。

三、Condition顺序访问案例

示例：多线程之间按顺序调用，实现AA -> BB -> CC依次打印。

案例分析：

要实现按顺序打印，那么是否要有一些标志，标志当前需要打印AA还是BB还是CC：

/*** 标志位* A ：1* B : 2* C : 3*/
private int number = 1;

当打印完AA后，将number修改为2，打印完BB后，将n的umber修改为3，打印完CC后将number修改为1，依次重复，然后再创建三个分别代表打印AA/BB/CC的Condition绑定到Lock上。

/*** 多线程之间按顺序调用，实现AA->BB->CC依次打印* 也即精确通知顺序访问*/
public class T07_ConditionDemo {public static void main(String[] args) {ShareData shareData = new ShareData();new Thread(() -> {for (int i = 0; i < 3; i++) {shareData.printAA();}}).start();new Thread(() -> {for (int i = 0; i < 3; i++) {shareData.printBB();}}).start();new Thread(() -> {for (int i = 0; i < 3; i++) {shareData.printCC();System.out.println("===================");}}).start();}
}class ShareData {/*** 标志位* A ：1* B : 2* C : 3*/private int number = 1;/*** 可重入锁*/private Lock lock = new ReentrantLock();/*** 打印AA的条件*/private Condition conditionA = lock.newCondition();/*** 打印BB的条件*/private Condition conditionB = lock.newCondition();/*** 打印CC的条件*/private Condition conditionC = lock.newCondition();public void printAA() {lock.lock();try {while (number != 1) {conditionA.await();}for (int i = 0; i <= 4; i++) {System.out.println("AA");}number = 2;//唤醒打印BB的线程conditionB.signal();} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}}public void printBB() {lock.lock();try {while (number != 2) {conditionB.await();}for (int i = 0; i < 5; i++) {System.out.println("BB");}number = 3;//唤醒打印CC的线程conditionC.signal();} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}}public void printCC() {lock.lock();try {while (number != 3) {conditionC.await();}for (int i = 0; i < 5; i++) {System.out.println("CC");}number = 1;//唤醒打印AA的线程conditionA.signal();} catch (InterruptedException e) {e.printStackTrace();} finally {lock.unlock();}}
}

运行结果：

AA
AA
AA
AA
AA
BB
BB
BB
BB
BB
CC
CC
CC
CC
CC
AA
AA
AA
AA
AA
===================
BB
BB
BB
BB
BB
CC
CC
CC
CC
CC
===================
AA
AA
AA
AA
AA
BB
BB
BB
BB
BB
CC
CC
CC
CC
CC
===================

以上就是使用Condition实现了精确通知某个线程然后按顺序访问。