wait/notify交替输出100以内的数
实现如下：
- 该版本的实现完全依赖 wait / notify
class Test {
public static int i = 0;
public static Object object = new Object();
public static void main(String[] args) {
Thread[] t = new Thread[3];
Thread t1 = new Thread(()-> {
while (i < 100) {
synchronized (object) {
try {
object.wait();
// t2 线程唤醒 t1 线程后理应等待进入 wait，但是如果在 t2 线程进入 wait
// 的这段时间内 t1 线程迅速输出并 notify 则此时会让 t1、t2 两个线程都
// 进入 wait 造成活锁。因此 t1 线程 notify 之前必须保证 t2 线程状态
// 是 wait
while (!Thread.State.WAITING.equals(t[2].getState())) {
object.wait(1);
}
System.out.println("t2：B" + i++);
object.notify();
} catch (Exception e) {
}
}
}
});
Thread t2 = new Thread(() -> {
while (i < 100) {
synchronized (object) {
try {
while (!Thread.State.WAITING.equals(t[1].getState())) {
object.wait(1);
}
System.out.println("t1：A" + i++);
object.notify();
object.wait();
} catch (Exception e) {
}
}
}
});
t[1] = t1;
t[2] = t2;
t1.start();
t2.start();
}
}- 也可以不使用 wait / notify，以下代码需要在 jvm 启动参数上添加
-Xint使 jvm 仅在解释器模式下运行，不触发 c1、c2 的代码优化。以下代码在不加参数-Xint时也能得到期望的结果，但是一旦把循环次数加到 2000 以上就会开始频繁出现线程安全问题，本质还是需要注意 c1、c2 对代码的优化。
public class Test {
private static int i = 0;
public static void main(String[] args) {
new Thread(() -> {
while (i < 99) {
if (i % 2 == 0) {
System.out.println("t1: A");
i++;
}
}
}).start();
new Thread(() -> {
while (i < 100) {
if (i % 2 == 1) {
System.out.println("t2: B");
i++;
}
}
}).start();
}
}wait / notify 顺序输出 A、B、C
解决方案：既然两个线程可用 wait / notify 交替输出，那么把3个线程当作 2 个线程问题即可解决，将线程 1 视为 1 个整体，2、3视为一个整体。此时需要两个对象监视器分别为 object1、object2，object1 控制 1、2，object2 控制 2，3。具体如图所示：
一个循环流程如下表：
| 时刻 | t1线程状态 | t2线程状态 | t3线程状态 |
|---|---|---|---|
0 | runing | wait(object1) | wait(object2) |
1 | nofity(object1) | wait(object1) | wait(object2) |
2 | wait(object1) | runing | wait(object2) |
3 | wait(object1) | notify(object2) | wait(object2) |
4 | wait(object1) | wait(object2) | runing |
5 | wait(object1) | wait(object2) | notify(object2) |
6 | wait(object1) | notify(object1) | wait(object2) |
7 | runing | wait(object1) | wait(object2) |
代码如下：
class test {
public static int i = 0;
public static Object object1 = new Object();
public static Object object2 = new Object();
public static void main(String[] args) {
Thread[] t = new Thread[4];
Thread t1 = new Thread(()-> {
while (i < 10000) {
synchronized (object2) {
try {
object2.wait();
System.out.println("t3：" + i++);
while (!Thread.State.WAITING.equals(t[2].getState())) {
object2.wait(1);
}
object2.notify();
} catch (Exception e) {
}
}
}
});
Thread t2 = new Thread(()-> {
while (i < 10000) {
synchronized (object1) {
try {
object1.wait();
synchronized (object2) {
System.out.println("t2：" + i++);
while (!Thread.State.WAITING.equals(t[1].getState())) {
object2.wait(1);
}
object2.notify();
object2.wait();
}
while (!Thread.State.WAITING.equals(t[3].getState())) {
object1.wait(1);
}
object1.notify();
} catch (Exception e) {
}
}
}
});
Thread t3 = new Thread(()-> {
while (i < 10000) {
synchronized (object1) {
try {
System.out.println("t1：" + i++);
while (!Thread.State.WAITING.equals(t[2].getState())) {
object1.wait(1);
}
object1.notify();
object1.wait();
} catch (Exception e) {
}
}
}
});
t[1] = t1;
t[2] = t2;
t[3] = t3;
t3.start();
t2.start();
t1.start();
}
}