4.1 案例分析
其实代码写起来也没什么特别的，就是condition.signal()可以唤醒指定的线程。看代码就知道怎么写了，不是以参数的方式来写的哦～
代码：
package communicate;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class ThreadDemo3 {
public static void main(String[] args) {
Share3 share3 = new Share3();
new Thread(()->{
for(int i = 0; i < 10; i++) {
try{
share3.printAA();
} catch (Exception e) {
e.printStackTrace();
}
}
}, "AA").start();
new Thread(()->{
for(int i = 0; i < 10; i++) {
try{
share3.printBB();
} catch (Exception e) {
e.printStackTrace();
}
}
}, "BB").start();
new Thread(()->{
for(int i = 0; i < 10; i++) {
try{
share3.printCC();
} catch (Exception e) {
e.printStackTrace();
}
}
}, "CC").start();
}
}
class Share3 {
private int flag = 1;
private Lock lock = new ReentrantLock();
private Condition condition1 = lock.newCondition();
private Condition condition2 = lock.newCondition();
private Condition condition3 = lock.newCondition();
public void printAA() throws InterruptedException {
lock.lock();
try {
while(flag != 1) {
condition1.await();
}
for(int i = 0; i < 5; i++) {
System.out.println(Thread.currentThread().getName());
}
flag = 2;
condition2.signal();
}
finally {
lock.unlock();
}
}
public void printBB() throws InterruptedException {
lock.lock();
try {
while(flag != 2) {
condition2.await();
}
for(int i = 0; i < 10; i++) {
System.out.println(Thread.currentThread().getName());
}
flag = 3;
condition3.signal();
}
finally {
lock.unlock();
}
}
public void printCC() throws InterruptedException {
lock.lock();
try {
while(flag != 3) {
condition3.await();
}
for(int i = 0; i < 15; i++) {
System.out.println(Thread.currentThread().getName());
}
flag = 1;
condition1.signal();
}
finally {
lock.unlock();
}
}
}