Java 生產(chǎn)者/消費(fèi)者問(wèn)題實(shí)例詳解
生產(chǎn)者和消費(fèi)者問(wèn)題是線(xiàn)程模型中的經(jīng)典問(wèn)題:生產(chǎn)者和消費(fèi)者在同一時(shí)間段內(nèi)共用同一個(gè)存儲(chǔ)空間,如下圖所示,生產(chǎn)者向空間里存放數(shù)據(jù),而消費(fèi)者取用數(shù)據(jù),如果不加以協(xié)調(diào)可能會(huì)出現(xiàn)以下情況:
存儲(chǔ)空間已滿(mǎn),而生產(chǎn)者占用著它,消費(fèi)者等著生產(chǎn)者讓出空間從而去除產(chǎn)品,生產(chǎn)者等著消費(fèi)者消費(fèi)產(chǎn)品,從而向空間中添加產(chǎn)品?;ハ嗟却?,從而發(fā)生死鎖。
以下實(shí)例演示了如何通過(guò)線(xiàn)程解決生產(chǎn)者/消費(fèi)者問(wèn)題:
/* author by w3cschool.cc 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
希望本篇文章對(duì)您有所幫助
- Java實(shí)現(xiàn)Kafka生產(chǎn)者消費(fèi)者代碼實(shí)例
- Java基于Lock的生產(chǎn)者消費(fèi)者模型示例
- kafka生產(chǎn)者和消費(fèi)者的javaAPI的示例代碼
- 基于Java 生產(chǎn)者消費(fèi)者模式(詳細(xì)分析)
- Java實(shí)現(xiàn)生產(chǎn)者消費(fèi)者問(wèn)題與讀者寫(xiě)者問(wèn)題詳解
- Java多線(xiàn)程之線(xiàn)程通信生產(chǎn)者消費(fèi)者模式及等待喚醒機(jī)制代碼詳解
- JAVA多線(xiàn)程實(shí)現(xiàn)生產(chǎn)者消費(fèi)者的實(shí)例詳解
- Java多種方式實(shí)現(xiàn)生產(chǎn)者消費(fèi)者模式
相關(guān)文章
Java多線(xiàn)程之synchronized同步代碼塊詳解
這篇文章主要為大家詳細(xì)介紹了Java多線(xiàn)程之synchronized同步代碼塊,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下,希望能夠給你帶來(lái)幫助2022-03-03Java 后端開(kāi)發(fā)中Tomcat服務(wù)器運(yùn)行不了的五種解決方案
tomcat是在使用Java編程語(yǔ)言開(kāi)發(fā)服務(wù)端技術(shù)使用最廣泛的服務(wù)器之一,但經(jīng)常在開(kāi)發(fā)項(xiàng)目的時(shí)候會(huì)出現(xiàn)運(yùn)行不了的情況,這里總結(jié)出幾種能解決的辦法2021-10-10java多線(xiàn)程之線(xiàn)程同步七種方式代碼示例
這篇文章主要介紹了java多線(xiàn)程之線(xiàn)程同步七種方式代碼示例,具有一定參考價(jià)值,需要的朋友可以了解下。2017-11-11Java使用ES?Client?調(diào)用滾動(dòng)查詢(xún)及Elasticsearch滾動(dòng)查詢(xún)Scrolling機(jī)制
Elasticsearch提供了一種稱(chēng)為"滾動(dòng)查詢(xún)"(Scrolling)的機(jī)制,用于處理大型數(shù)據(jù)集的分頁(yè)查詢(xún),這篇文章給大家介紹滾動(dòng)查詢(xún)的一般步驟及Java使用ESClient調(diào)用滾動(dòng)查詢(xún)的方法,感興趣的朋友一起看看吧2023-08-08Spring boot監(jiān)控Actuator-Admin實(shí)現(xiàn)過(guò)程詳解
這篇文章主要介紹了Spring boot監(jiān)控Actuator-Admin實(shí)現(xiàn)過(guò)程詳解,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09@Valid 校驗(yàn)無(wú)效,BindingResult未獲得錯(cuò)誤的解決
這篇文章主要介紹了@Valid 校驗(yàn)無(wú)效,BindingResult未獲得錯(cuò)誤的解決,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-10-10IntelliJ?IDEA教程之clean或者install?Maven項(xiàng)目的操作方法
這篇文章主要介紹了IntelliJ?IDEA教程之clean或者install?Maven項(xiàng)目的操作方法,本文分步驟給大家介紹兩種方式講解如何調(diào)試出窗口,需要的朋友可以參考下2023-04-04SpringBoot+Redis Bitmap實(shí)現(xiàn)活躍用戶(hù)統(tǒng)計(jì)
Redis的Bitmap數(shù)據(jù)結(jié)構(gòu)是一種緊湊的位圖,它可以用于實(shí)現(xiàn)各種場(chǎng)景,其中統(tǒng)計(jì)活躍用戶(hù)是一種經(jīng)典的業(yè)務(wù)場(chǎng)景,下面我們就來(lái)學(xué)習(xí)一下SpringBoot如何利用Redis中的Bitmap實(shí)現(xiàn)活躍用戶(hù)統(tǒng)計(jì)吧2023-11-11