線程協(xié)作
多線程協(xié)作的典型場景，生產(chǎn)者消費(fèi)者模型病游。JAVA 中提供的線程阻塞和線程喚醒 Api
被棄用的 suspend 和 resume
作用：通過 suspend 掛起目標(biāo)線程，通過 resume 喚醒線程改橘。
代碼演示：
public class Demo6 {
public static Object baozi;
// 正常的 suspend resume
public void suspendResumeTest() throws InterruptedException{
// 啟動線程
Thread consumerThread = new Thread(() -> {
// 沒有包子 則等待
if (baozi == null) {
System.out.println("1, 進(jìn)入等待");
Thread.currentThread().suspend();
}
// 買到包子
System.out.println("2, 買到包子了");
});
// 啟動進(jìn)程
consumerThread.start();
// 主進(jìn)程休眠3秒飞主，讓消費(fèi)進(jìn)程進(jìn)入掛起
Thread.sleep(3000);
// 生產(chǎn)包子碌识，通知消費(fèi)進(jìn)程
baozi = new Object();
consumerThread.resume();
System.out.println("3, 通知消費(fèi)者");
}
public static void main(String[] args) throws Exception{
new Demo6().suspendResumeTest();
}
}
問題 ：
- 不會釋放鎖
/** 死鎖的suspend/resume筏餐。 suspend并不會像wait一樣釋放鎖魁瞪，故此容易寫出死鎖代碼 */
public void suspendResumeDeadLockTest() throws Exception {
// 啟動線程
Thread consumerThread = new Thread(() -> {
if (baozidian == null) { // 如果沒包子导俘，則進(jìn)入等待
System.out.println("1剔蹋、進(jìn)入等待");
// 當(dāng)前線程拿到鎖泣崩，然后掛起
synchronized (this) {
Thread.currentThread().suspend();
}
}
System.out.println("2律想、買到包子，回家");
});
consumerThread.start();
// 3秒之后著洼，生產(chǎn)一個包子
Thread.sleep(3000L);
baozidian = new Object();
// 爭取到鎖以后而叼，再恢復(fù)consumerThread
synchronized (this) {
consumerThread.resume();
}
System.out.println("3葵陵、通知消費(fèi)者");
}
- 掛起必須在通知前
/** 導(dǎo)致程序永久掛起的suspend/resume */
public void suspendResumeDeadLockTest2() throws Exception {
// 啟動線程
Thread consumerThread = new Thread(() -> {
if (baozidian == null) {
System.out.println("1、沒包子娇钱，進(jìn)入等待");
try { // 為這個線程加上一點(diǎn)延時
Thread.sleep(5000L);
} catch (InterruptedException e) {
e.printStackTrace();
}
// 這里的掛起執(zhí)行在resume后面
Thread.currentThread().suspend();
}
System.out.println("2文搂、買到包子，回家");
});
consumerThread.start();
// 3秒之后笔喉，生產(chǎn)一個包子
Thread.sleep(3000L);
baozidian = new Object();
consumerThread.resume();
System.out.println("3常挚、通知消費(fèi)者");
consumerThread.join();
}
wait notify
wait 會讓當(dāng)前線程等待稽物，加入該對象的等待集合中，并且釋放當(dāng)前持有的對象鎖
notify/notityAll 用于h喚醒一個或所有等待對象鎖的線程
/** 正常的wait/notify */
public void waitNotifyTest() throws Exception {
// 啟動線程
new Thread(() -> {
if (baozidian == null) { // 如果沒包子秧倾，則進(jìn)入等待
synchronized (this) {
try {
System.out.println("1、進(jìn)入等待");
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
System.out.println("2农猬、買到包子斤葱，回家");
}).start();
// 3秒之后，生產(chǎn)一個包子
Thread.sleep(3000L);
baozidian = new Object();
synchronized (this) {
this.notifyAll();
System.out.println("3料身、通知消費(fèi)者");
}
}
問題 ：
- 掛起必須在通知前
/** 會導(dǎo)致程序永久等待的wait/notify */
public void waitNotifyDeadLockTest() throws Exception {
// 啟動線程
new Thread(() -> {
if (baozidian == null) { // 如果沒包子芹血，則進(jìn)入等待
try {
Thread.sleep(5000L);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
synchronized (this) {
try {
System.out.println("1幔烛、進(jìn)入等待");
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
System.out.println("2饿悬、買到包子聚霜，回家");
}).start();
// 3秒之后，生產(chǎn)一個包子
Thread.sleep(3000L);
baozidian = new Object();
synchronized (this) {
this.notifyAll();
System.out.println("3傲宜、通知消費(fèi)者");
}
}
park unpark
park 等待許可函卒，unpark 拿到許可，多次調(diào)用 unpark 之后虱咧，再調(diào)用park腕巡，線程會執(zhí)行血筑，但是 park 只有一次有效豺总，不能疊加喻喳，也就是 拿到的令牌 只能喚醒一次，下次 park 繼續(xù)等待表伦。
/** 正常的park/unpark */
public void parkUnparkTest() throws Exception {
// 啟動線程
Thread consumerThread = new Thread(() -> {
if (baozidian == null) { // 如果沒包子鳄哭，則進(jìn)入等待
System.out.println("1、進(jìn)入等待");
LockSupport.park();
}
System.out.println("2妆丘、買到包子飘痛，回家");
});
consumerThread.start();
// 3秒之后容握，生產(chǎn)一個包子
Thread.sleep(3000L);
baozidian = new Object();
LockSupport.unpark(consumerThread);
System.out.println("3、通知消費(fèi)者");
}
問題 ：
- 不會釋放鎖
/** 死鎖的park/unpark */
public void parkUnparkDeadLockTest() throws Exception {
// 啟動線程
Thread consumerThread = new Thread(() -> {
if (baozidian == null) { // 如果沒包子塑猖，則進(jìn)入等待
System.out.println("1塑陵、進(jìn)入等待");
// 當(dāng)前線程拿到鎖，然后掛起
synchronized (this) {
LockSupport.park();
}
}
System.out.println("2令花、買到包子兼都，回家");
});
consumerThread.start();
// 3秒之后扮碧，生產(chǎn)一個包子
Thread.sleep(3000L);
baozidian = new Object();
// 爭取到鎖以后慎王，再恢復(fù)consumerThread
synchronized (this) {
LockSupport.unpark(consumerThread);
}
System.out.println("3赖淤、通知消費(fèi)者");
}
偽喚醒
使用 if 判斷進(jìn)入等待是錯誤的负芋，官方建議在循環(huán)中檢查等待條件旧蛾，如果不再循環(huán)中檢查锨天，程序就會在沒有滿足條件的情況下推出病袄。
