兩個線程一個生產(chǎn)者個一個消費者
需求情景
兩個線程，一個負責(zé)生產(chǎn)，一個負責(zé)消費，生產(chǎn)者生產(chǎn)一個，消費者消費一個
『 資源被多個執(zhí)行緒並發(fā)存取時的完整性。常用的同步方法是採用標記或加鎖機制
wait() / nofity() 方法是基類Object的兩個方法，也就意味著所有Java類別都會擁有這兩個方法，這樣，我們就可以為任何物件實作同步機制。
wait()方法：當緩衝區(qū)已滿/空時，生產(chǎn)者/消費者執(zhí)行緒停止自己的執(zhí)行，放棄鎖，使自己處於等等狀態(tài)，讓其他執(zhí)行緒執(zhí)行。
notify()方法：當生產(chǎn)者/消費者向緩衝區(qū)放入/取出一個產(chǎn)品時，向其他等待的執(zhí)行緒發(fā)出可執(zhí)行的通知，同時放棄鎖，使自己處於等待狀態(tài)。
程式碼實作(共三個類別和一個main方法的測試類別)
Resource.java
/**
* Created by yuandl on 2016-10-11./**
* 資源
*/
public class Resource {
/*資源序號*/
private int number = 0;
/*資源標記*/
private boolean flag = false;
/**
* 生產(chǎn)資源
*/
public synchronized void create() {
if (flag) {//先判斷標記是否已經(jīng)生產(chǎn)了，如果已經(jīng)生產(chǎn)，等待消費;
try {
wait();//讓生產(chǎn)線程等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
number++;//生產(chǎn)一個
System.out.println(Thread.currentThread().getName() + "生產(chǎn)者------------" + number);
flag = true;//將資源標記為已經(jīng)生產(chǎn)
notify();//喚醒在等待操作資源的線程(隊列)
}
/**
* 消費資源
*/
public synchronized void destroy() {
if (!flag) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName() + "消費者****" + number);
flag = false;
notify();
}
}Producer.java
ProducerConsumerTest.java /**
* Created by yuandl on 2016-10-11.
*
/**
* 生產(chǎn)者
*/
public class Producer implements Runnable {
private Resource resource;
public Producer(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
resource.create();
}
}
}
/**
* 消費者
*/
public class Consumer implements Runnable {
private Resource resource;
public Consumer(Resource resource) {
this.resource = resource;
}
@Override
public void run() {
while (true) {
try {
Thread.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
resource.destroy();
}
}
}
多個線程，多個生產(chǎn)者和多個消費者的問題
多個需求
『兩個個負責(zé)消費，生產(chǎn)者生產(chǎn)一個，消費者消費一個涉及問題
notifyAll()方法：當生產(chǎn)者/消費者向緩衝區(qū)放入/取出一個產(chǎn)品時，向其他等待的所有線程發(fā)出可執(zhí)行的通知，同時放棄鎖，使自己處於等待狀態(tài)。
再次測試代碼
/**
* Created by yuandl on 2016-10-11.
*/
public class ProducerConsumerTest {
public static void main(String args[]) {
Resource resource = new Resource();
new Thread(new Producer(resource)).start();//生產(chǎn)者線程
new Thread(new Consumer(resource)).start();//消費者線程
}
}運行結(jié)果
Thread-0生產(chǎn)者------------1 Thread-1消費者****1 Thread-0生產(chǎn)者------------2 Thread-1消費者****2 Thread-0生產(chǎn)者------------3 Thread-1消費者****3 Thread-0生產(chǎn)者------------4 Thread-1消費者****4 Thread-0生產(chǎn)者------------5 Thread-1消費者****5 Thread-0生產(chǎn)者------------6 Thread-1消費者****6 Thread-0生產(chǎn)者------------7 Thread-1消費者****7 Thread-0生產(chǎn)者------------8 Thread-1消費者****8 Thread-0生產(chǎn)者------------9 Thread-1消費者****9 Thread-0生產(chǎn)者------------10 Thread-1消費者****10
透過以上列印結(jié)果發(fā)現(xiàn)問題
ProducerConsumerTest.java
/**
* Created by yuandl on 2016-10-11.
*/
public class ProducerConsumerTest {
public static void main(String args[]) {
Resource resource = new Resource();
new Thread(new Consumer(resource)).start();//生產(chǎn)者線程
new Thread(new Consumer(resource)).start();//生產(chǎn)者線程
new Thread(new Producer(resource)).start();//消費者線程
new Thread(new Producer(resource)).start();//消費者線程
}
}透過以上列印結(jié)果發(fā)現(xiàn)問題?? 05生產(chǎn)了，沒有消費
原因分析
當兩個線程同時操作生產(chǎn)者生產(chǎn)或者消費者消費時，如果有生產(chǎn)者或者的兩個線程都wait()時，再次notify(),由於其中一個線程已經(jīng)改變了標記而另外一個線程再次往下直接執(zhí)行的時候沒有判斷標記而導(dǎo)致的。if判斷標記，只有一次，會導(dǎo)致不該運行的執(zhí)行緒運行了。出現(xiàn)了數(shù)據(jù)錯誤的情況。
解決方案
while判斷標記，解決了線程獲取執(zhí)行權(quán)後，是否要運行!也就是每次wait()後再notify()時先再次判斷標記
while)
Resource.java
Thread-0生產(chǎn)者------------100 Thread-3消費者****100 Thread-0生產(chǎn)者------------101 Thread-3消費者****101 Thread-2消費者****101 Thread-1生產(chǎn)者------------102 Thread-3消費者****102 Thread-0生產(chǎn)者------------103 Thread-2消費者****103 Thread-1生產(chǎn)者------------104 Thread-3消費者****104 Thread-1生產(chǎn)者------------105 Thread-0生產(chǎn)者------------106 Thread-2消費者****106 Thread-1生產(chǎn)者------------107 Thread-3消費者****107 Thread-0生產(chǎn)者------------108 Thread-2消費者****108 Thread-0生產(chǎn)者------------109 Thread-2消費者****109 Thread-1生產(chǎn)者------------110 Thread-3消費者****110
再次發(fā)現(xiàn)問題
印到某個值例如生產(chǎn)完74，程式運作卡死了，好像鎖死了一樣。
原因分析
notify:只能喚醒一個線程，如果本方喚醒了本方，沒有意義。而且while判斷標記+notify會導(dǎo)致」死鎖」。
解決方案
notifyAll解決了本方執(zhí)行緒一定會喚醒對方執(zhí)行緒的問題。
最後程式碼改進(Resource中的notify()->notifyAll())
Resource.java
/**
* Created by yuandl on 2016-10-11./**
* 資源
*/
public class Resource {
/*資源序號*/
private int number = 0;
/*資源標記*/
private boolean flag = false;
/**
* 生產(chǎn)資源
*/
public synchronized void create() {
while (flag) {//先判斷標記是否已經(jīng)生產(chǎn)了，如果已經(jīng)生產(chǎn)，等待消費;
try {
wait();//讓生產(chǎn)線程等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
number++;//生產(chǎn)一個
System.out.println(Thread.currentThread().getName() + "生產(chǎn)者------------" + number);
flag = true;//將資源標記為已經(jīng)生產(chǎn)
notify();//喚醒在等待操作資源的線程(隊列)
}
/**
* 消費資源
*/
public synchronized void destroy() {
while (!flag) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName() + "消費者****" + number);
flag = false;
notify();
}
}告
/**
* Created by yuandl on 2016-10-11./**
* 資源
*/
public class Resource {
/*資源序號*/
private int number = 0;
/*資源標記*/
private boolean flag = false;
/**
* 生產(chǎn)資源
*/
public synchronized void create() {
while (flag) {//先判斷標記是否已經(jīng)生產(chǎn)了，如果已經(jīng)生產(chǎn)，等待消費;
try {
wait();//讓生產(chǎn)線程等待
} catch (InterruptedException e) {
e.printStackTrace();
}
}
number++;//生產(chǎn)一個
System.out.println(Thread.currentThread().getName() + "生產(chǎn)者------------" + number);
flag = true;//將資源標記為已經(jīng)生產(chǎn)
notifyAll();//喚醒在等待操作資源的線程(隊列)
}
/**
* 消費資源
*/
public synchronized void destroy() {
while (!flag) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName() + "消費者****" + number);
flag = false;
notifyAll();
}
}告
?告
熱AI工具
Undress AI Tool
免費脫衣圖片
Undresser.AI Undress
人工智慧驅(qū)動的應(yīng)用程序，用於創(chuàng)建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發(fā)環(huán)境
Dreamweaver CS6
視覺化網(wǎng)頁開發(fā)工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
熱門話題
Java vs. JavaScript：清除混亂
Jun 20, 2025 am 12:27 AM
Java和JavaScript是不同的編程語言，各自適用於不同的應(yīng)用場景。 Java用於大型企業(yè)和移動應(yīng)用開發(fā)，而JavaScript主要用於網(wǎng)頁開發(fā)。
JavaScript評論：簡短說明
Jun 19, 2025 am 12:40 AM
JavascriptconcommentsenceenceEncorenceEnterential gransimenting，reading and guidingCodeeXecution.1）單inecommentsareusedforquickexplanations.2）多l(xiāng)inecommentsexplaincomplexlogicorprovideDocumentation.3）
如何在JS中與日期和時間合作？
Jul 01, 2025 am 01:27 AM
JavaScript中的日期和時間處理需注意以下幾點：1.創(chuàng)建Date對像有多種方式，推薦使用ISO格式字符串以保證兼容性；2.獲取和設(shè)置時間信息可用get和set方法，注意月份從0開始；3.手動格式化日期需拼接字符串，也可使用第三方庫；4.處理時區(qū)問題建議使用支持時區(qū)的庫，如Luxon。掌握這些要點能有效避免常見錯誤。
為什麼要將標籤放在的底部？
Jul 02, 2025 am 01:22 AM
PlacingtagsatthebottomofablogpostorwebpageservespracticalpurposesforSEO,userexperience,anddesign.1.IthelpswithSEObyallowingsearchenginestoaccesskeyword-relevanttagswithoutclutteringthemaincontent.2.Itimprovesuserexperiencebykeepingthefocusonthearticl
JavaScript與Java：開發(fā)人員的全面比較
Jun 20, 2025 am 12:21 AM
JavaScriptIspreferredforredforwebdevelverment，而Javaisbetterforlarge-ScalebackendsystystemsandSandAndRoidApps.1）JavascriptexcelcelsincreatingInteractiveWebexperienceswebexperienceswithitswithitsdynamicnnamicnnamicnnamicnnamicnemicnemicnemicnemicnemicnemicnemicnemicnddommanipulation.2）
JavaScript：探索用於高效編碼的數(shù)據(jù)類型
Jun 20, 2025 am 12:46 AM
javascripthassevenfundaMentalDatatypes：數(shù)字，弦，布爾值，未定義，null，object和symbol.1）numberSeadUble-eaduble-ecisionFormat，forwidevaluerangesbutbecautious.2）
什麼是在DOM中冒泡和捕獲的事件？
Jul 02, 2025 am 01:19 AM
事件捕獲和冒泡是DOM中事件傳播的兩個階段，捕獲是從頂層向下到目標元素，冒泡是從目標元素向上傳播到頂層。 1.事件捕獲通過addEventListener的useCapture參數(shù)設(shè)為true實現(xiàn)；2.事件冒泡是默認行為，useCapture設(shè)為false或省略；3.可使用event.stopPropagation()阻止事件傳播；4.冒泡支持事件委託，提高動態(tài)內(nèi)容處理效率；5.捕獲可用於提前攔截事件，如日誌記錄或錯誤處理。了解這兩個階段有助於精確控制JavaScript響應(yīng)用戶操作的時機和方式。
Java和JavaScript有什麼區(qū)別？
Jun 17, 2025 am 09:17 AM
Java和JavaScript是不同的編程語言。 1.Java是靜態(tài)類型、編譯型語言，適用於企業(yè)應(yīng)用和大型系統(tǒng)。 2.JavaScript是動態(tài)類型、解釋型語言，主要用於網(wǎng)頁交互和前端開發(fā)。
