Java如何通過線程解決生產(chǎn)者/消費(fèi)者問題
生產(chǎn)者和消費(fèi)者問題是線程模型中的經(jīng)典問題:生產(chǎn)者和消費(fèi)者在同一時(shí)間段內(nèi)共用同一個(gè)存儲(chǔ)空間,如下圖所示
生產(chǎn)者向空間里存放數(shù)據(jù),而消費(fèi)者取用數(shù)據(jù),如果不加以協(xié)調(diào)可能會(huì)出現(xiàn)以下情況:
存儲(chǔ)空間已滿,而生產(chǎn)者占用著它,消費(fèi)者等著生產(chǎn)者讓出空間從而去除產(chǎn)品,生產(chǎn)者等著消費(fèi)者消費(fèi)產(chǎn)品,從而向空間中添加產(chǎn)品。互相等待,從而發(fā)生死鎖。
以下實(shí)例演示了如何通過線程解決生產(chǎn)者/消費(fèi)者問題:
/* author by javaidea.com ProducerConsumerTest.java */public class ProducerConsumerTest { public static void main(String[] args) { CubbyHole c = new CubbyHole(); Producer p1 = new Producer(c, 1); Consumer c1 = new Consumer(c, 1); p1.start(); c1.start(); }}class CubbyHole { private int contents; private boolean available = false; public synchronized int get() { while (available == false) { try { wait(); } catch (InterruptedException e) { } } available = false; notifyAll(); return contents; } public synchronized void put(int value) { while (available == true) { try { wait(); } catch (InterruptedException e) { } } contents = value; available = true; notifyAll(); }}class Consumer extends Thread { private CubbyHole cubbyhole; private int number; public Consumer(CubbyHole c, int number) { cubbyhole = c; this.number = number; } public void run() { int value = 0; for (int i = 0; i < 10; i++) { value = cubbyhole.get(); System.out.println('消費(fèi)者 #' + this.number+ ' got: ' + value); } }}class Producer extends Thread { private CubbyHole cubbyhole; private int number; public Producer(CubbyHole c, int number) { cubbyhole = c; this.number = number; } public void run() { for (int i = 0; i < 10; i++) { cubbyhole.put(i); System.out.println('生產(chǎn)者 #' + this.number + ' put: ' + i); try { sleep((int)(Math.random() * 100)); } catch (InterruptedException e) { } } }}
以上代碼運(yùn)行輸出結(jié)果為:
消費(fèi)者 #1 got: 0生產(chǎn)者 #1 put: 0生產(chǎn)者 #1 put: 1消費(fèi)者 #1 got: 1生產(chǎn)者 #1 put: 2消費(fèi)者 #1 got: 2生產(chǎn)者 #1 put: 3消費(fèi)者 #1 got: 3生產(chǎn)者 #1 put: 4消費(fèi)者 #1 got: 4生產(chǎn)者 #1 put: 5消費(fèi)者 #1 got: 5生產(chǎn)者 #1 put: 6消費(fèi)者 #1 got: 6生產(chǎn)者 #1 put: 7消費(fèi)者 #1 got: 7生產(chǎn)者 #1 put: 8消費(fèi)者 #1 got: 8生產(chǎn)者 #1 put: 9消費(fèi)者 #1 got: 9
以上就是Java如何通過線程解決生產(chǎn)者/消費(fèi)者問題的詳細(xì)內(nèi)容,更多關(guān)于Java 解決生產(chǎn)者/消費(fèi)者問題的資料請(qǐng)關(guān)注好吧啦網(wǎng)其它相關(guān)文章!
相關(guān)文章:
1. 完美解決vue 中多個(gè)echarts圖表自適應(yīng)的問題2. SpringBoot+TestNG單元測(cè)試的實(shí)現(xiàn)3. vue實(shí)現(xiàn)web在線聊天功能4. idea配置jdk的操作方法5. Springboot 全局日期格式化處理的實(shí)現(xiàn)6. python 浮點(diǎn)數(shù)四舍五入需要注意的地方7. Docker容器如何更新打包并上傳到阿里云8. IntelliJ IDEA設(shè)置默認(rèn)瀏覽器的方法9. Java GZip 基于內(nèi)存實(shí)現(xiàn)壓縮和解壓的方法10. JAMon(Java Application Monitor)備忘記
