package com.kang.multithread;
/**
* @author klr
* @create 2020-09-16-11:11
*/
public class AlternateOutput {
static final Object lock = new Object();
static boolean con1 = false;
static boolean con2 = false;
public static void main(String[] args) throws InterruptedException {
Thread t1 = new Thread(()->{
synchronized (lock) {
for (int i = 0; i < 5; i++) {
while (con1 || con2) {
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("a");
con1 = true;
lock.notifyAll();
}
}
},"t1");
Thread t2 = new Thread(()->{
synchronized (lock) {
for (int i = 0; i < 5; i++) {
while (!con1) {
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("b");
con1=false;
con2=true;
lock.notifyAll();
}
}
},"t2");
Thread t3 = new Thread(()->{
synchronized (lock) {
for (int i = 0; i < 5; i++) {
while (!con2) {
try {
lock.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("c");
con2=false;
lock.notifyAll();
}
}
},"t3");
t1.start();
t2.start();
t3.start();
t1.join();
t2.join();
t3.join();
}
}
网友评论