這篇文章主要為大家展示了Java如何實(shí)現(xiàn)簡易生產(chǎn)者消費(fèi)者模型,內(nèi)容簡而易懂,希望大家可以學(xué)習(xí)一下,學(xué)習(xí)完之后肯定會(huì)有收獲的,下面讓小編帶大家一起來看看吧。
創(chuàng)新互聯(lián)專注于成都網(wǎng)站建設(shè)、成都網(wǎng)站制作、網(wǎng)頁設(shè)計(jì)、網(wǎng)站制作、網(wǎng)站開發(fā)。公司秉持“客戶至上,用心服務(wù)”的宗旨,從客戶的利益和觀點(diǎn)出發(fā),讓客戶在網(wǎng)絡(luò)營銷中找到自己的駐足之地。尊重和關(guān)懷每一位客戶,用嚴(yán)謹(jǐn)?shù)膽B(tài)度對待客戶,用專業(yè)的服務(wù)創(chuàng)造價(jià)值,成為客戶值得信賴的朋友,為客戶解除后顧之憂。
一、概述
一共兩個(gè)線程,一個(gè)線程生產(chǎn)產(chǎn)品,一個(gè)線程消費(fèi)產(chǎn)品,使用同步代碼塊方法,同步兩個(gè)線程。當(dāng)產(chǎn)品沒有時(shí),通知生產(chǎn)者生產(chǎn),生產(chǎn)者生產(chǎn)后,通知消費(fèi)者消費(fèi),并等待消費(fèi)者消費(fèi)完。
需要注意的是,有可能出現(xiàn),停止生產(chǎn)產(chǎn)品后,消費(fèi)者還沒未來得及消費(fèi)生產(chǎn)者生產(chǎn)的最后一個(gè)產(chǎn)品,就結(jié)束消費(fèi),導(dǎo)致最后一個(gè)產(chǎn)品沒有被消費(fèi)。
本例使用synchronize以及wait()、notify()實(shí)現(xiàn)簡易版的線程者消費(fèi)者模型。
二、測試用例
這里的產(chǎn)品用筆來演示,每只筆都有其編號code
一共有四個(gè)類:分別是生產(chǎn)者類,產(chǎn)品類,消費(fèi)者類,測試類
產(chǎn)品
package test.exception.producer_consumer_model; /* 假設(shè)為產(chǎn)品為筆 */ public class Production { private String type = ""; private String color = ""; private long code = 0; // 產(chǎn)品編號 private boolean isProduced = false; // 是否生產(chǎn)完成 初始狀態(tài)為未生產(chǎn)狀態(tài) private boolean isContinueProduce = true; // 是否停產(chǎn)該產(chǎn)品 public void setContinueProduce(boolean continueProduce) { isContinueProduce = continueProduce; } public void setCode(long code) { this.code = code; } public Production(){ } public boolean isContinueProduce() { return isContinueProduce; } public void setType(String type) { this.type = type; } public void setColor(String color) { this.color = color; } public void setProduced(boolean produced) { isProduced = produced; } public boolean isProduced() { return isProduced; } @Override public String toString() { return color + type + "-" + code; } }
生產(chǎn)者
package test.exception.producer_consumer_model; public class Producer implements Runnable { private final Production pen; // 產(chǎn)品 public Producer(Production pen) { this.pen = pen; } // 生產(chǎn) public void produce() { long code = 0; while (this.pen.isContinueProduce()) { synchronized (this.pen) { if (this.pen.isProduced()) { try { this.pen.wait(); // 等待消費(fèi)者消費(fèi) } catch (InterruptedException e) { e.printStackTrace(); } } // 開始生產(chǎn) this.pen.setType("鉛筆"); this.pen.setColor("藍(lán)色"); this.pen.setCode(code++); this.pen.setProduced(true); System.out.println(this.pen + " is produced"); this.pen.notify(); } } System.out.println("finish producing"); } @Override public void run() { produce(); } }
消費(fèi)者
package test.exception.producer_consumer_model; public class Consumer implements Runnable { private final Production pen; public Consumer(Production pen) { this.pen = pen; } // 持續(xù)消費(fèi) public void consumer() { while (this.pen.isContinueProduce()) { synchronized (this.pen) { if (!this.pen.isProduced()) { try { this.pen.wait(); // 等待生產(chǎn)者生產(chǎn) } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println(this.pen + " is consumed"); // 使用 this.pen.setProduced(false); // 使用完后更新狀態(tài) this.pen.notify(); } } // 確保停止生產(chǎn)后,能夠使用最后生產(chǎn)的一支筆 if (this.pen.isProduced()) { System.out.println(this.pen + " is consumed"); } System.out.println("finish using"); } @Override public void run() { consumer(); } }
主線程測試
package test.exception.producer_consumer_model; public class Demo { public static void main(String[] args) throws InterruptedException { Production pen = new Production(); Consumer consumer = new Consumer(pen); Producer producer = new Producer(pen); new Thread(producer).start(); // 開啟生產(chǎn)者線程 new Thread(consumer).start(); // 開啟消費(fèi)者線程 Thread.sleep(10000); pen.setContinueProduce(false); // 10s后停止生產(chǎn)該類型的筆 } }
運(yùn)行結(jié)果
以上就是關(guān)于Java如何實(shí)現(xiàn)簡易生產(chǎn)者消費(fèi)者模型的內(nèi)容,如果你們有學(xué)習(xí)到知識或者技能,可以把它分享出去讓更多的人看到。
網(wǎng)站標(biāo)題:Java如何實(shí)現(xiàn)簡易生產(chǎn)者消費(fèi)者模型
分享URL:http://muchs.cn/article30/jehgpo.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站策劃、網(wǎng)站營銷、云服務(wù)器、小程序開發(fā)、虛擬主機(jī)、網(wǎng)站排名
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)