Java精講：生產者-消費者
原文連接
更多教程
本文概要
生產者和消費者問題是線程模型中老生常談的問題，也是面試中常常遇到的問題。光在Java中的實現方式多達數十種，更不用說加上其餘語言的實現方式了。那麼咱們該如何學習呢？java
本文會經過精講wait()和notify()方法實現生產者-消費者模型，來學習生產者和消費者問題的原理。android
目的是當你理解了最簡單實現原理，再看其餘的實現，無非使用了更高級的機制（例如鎖、信號量、管道等等）來照貓畫虎的實現這個原理，萬變不離其宗，它們的原理都是同樣的。面試
本文也會列出一部分其餘的實現方式代碼。千萬不要嘗試去背誦全部實現代碼，只有掌握了實現原理才能遇到問題的時候遊刃有餘。ide
精講wait()和notify()方法實現生產者-消費者模型
- 啥是生產者-消費者模型：
生產者和消費者在同一時間段內共用同一個存儲空間，生產者往存儲空間中添加產品，消費者從存儲空間中取走產品，當存儲空間爲空時，消費者阻塞，當存儲空間滿時，生產者阻塞。
現實生活中的例子：12306搶購火車票、淘寶購買商品、倉庫管理等。函數
- 分步的實現咱們的模型
public class Test1 {
private static Integer count = 0; //表明生產的商品數量
private static final Integer FULL = 10; //表明商品最多多少個（也就是緩衝區大小）
private static final Object LOCK = new Object(); //鎖對象 ----分析1
public static void main(String[] args) {
for (int i = 0; i < 5; i++) { //創造一堆生產者和消費者模擬真實環境
new Thread(new Producer()).start();
}
for (int i = 0; i < 5; i++) {
new Thread(new Consumer()).start();
}
}
static class Producer implements Runnable { //表明生產者
@Override
public void run() {
}
}
static class Consumer implements Runnable { //表明消費者
@Override
public void run() {
}
}
}
分析1.在main函數中建立了5個消費者線程任務和5個生產者線程任務，當這10個線程同時運行時，須要保證生產者和消費者所公用的緩衝區是同步被改變的，就是說不一樣線程訪問緩衝區的數據不能發生錯亂。這裏就是用一個鎖來保證緩衝區每次只有一個線程訪問學習
接下來看下生產者和消費者的實現：spa
static class Producer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) { //一次多生產幾個商品
try {
Thread.sleep(3000); //模擬真實環境，讓生產的慢一點，間隔3秒
} catch (Exception e) {
e.printStackTrace();
}
synchronized (LOCK) { //線程同步
while (count.equals(FULL)) { //當緩衝區滿了
try {
LOCK.wait(); //讓線程等待 ----分析1
} catch (Exception e) {
e.printStackTrace();
}
}
count++; //緩衝區不滿時繼續生產商品，商品加一
System.out.println(Thread.currentThread().getName() + "生產者生產，目前總共有" + count);
LOCK.notifyAll(); //喚醒等待的消費者
}
}
}
}
static class Consumer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
synchronized (LOCK) {
while (count == 0) { //當沒有商品時，須要等待生產者生產商品
try {
LOCK.wait(); //----分析 2
} catch (Exception e) {
}
}
count--; //商品被消耗，商品減一
System.out.println(Thread.currentThread().getName() + "消費者消費，目前總共有" + count);
LOCK.notifyAll(); //商品被消耗後，通知等待的生產者
}
}
}
}
分析：
1.當緩衝區滿了的時候，須要阻止生產者繼續生產商品
2.當緩衝區爲空，沒有商品時，須要阻止消費者繼續消費商品線程
相信代碼分析和詳細的註釋，你已經能很好的理解這個生產者-消費者模型的原理了。接下來貼出其餘的幾種實現代碼。code
原文連接
更多教程
其餘的實現方法代碼
使用鎖實現：對象
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Test1 {
private static Integer count = 0;
private static final Integer FULL = 10;
//建立一個鎖對象
private Lock lock = new ReentrantLock();
//建立兩個條件變量，一個爲緩衝區非滿，一個爲緩衝區非空
private final Condition notFull = lock.newCondition();
private final Condition notEmpty = lock.newCondition();
public static void main(String[] args) {
Test1 test1 = new Test1();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
}
class Producer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (Exception e) {
e.printStackTrace();
}
//獲取鎖
lock.lock();
try {
while (count == FULL) {
try {
notFull.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
count++;
System.out.println(Thread.currentThread().getName()
+ "生產者生產，目前總共有" + count);
//喚醒消費者
notEmpty.signal();
} finally {
//釋放鎖
lock.unlock();
}
}
}
}
class Consumer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
lock.lock();
try {
while (count == 0) {
try {
notEmpty.await();
} catch (Exception e) {
e.printStackTrace();
}
}
count--;
System.out.println(Thread.currentThread().getName()
+ "消費者消費，目前總共有" + count);
notFull.signal();
} finally {
lock.unlock();
}
}
}
}
}
使用阻塞隊列：
當隊列滿了或空了的時候進行入隊列操做都會被阻塞。
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
public class Test1 {
private static Integer count = 0;
//建立一個阻塞隊列
final BlockingQueue blockingQueue = new ArrayBlockingQueue<>(10);
public static void main(String[] args) {
Test1 test1 = new Test1();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
new Thread(test1.new Producer()).start();
new Thread(test1.new Consumer()).start();
}
class Producer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (Exception e) {
e.printStackTrace();
}
try {
blockingQueue.put(1);
count++;
System.out.println(Thread.currentThread().getName()
+ "生產者生產，目前總共有" + count);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Consumer implements Runnable {
@Override
public void run() {
for (int i = 0; i < 10; i++) {
try {
Thread.sleep(3000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
try {
blockingQueue.take();
count--;
System.out.println(Thread.currentThread().getName()
+ "消費者消費，目前總共有" + count);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
原文連接
更多教程
相關文章
- 1. 生產者和消費者
- 2. 生產者消費者
- 3. 生產者與消費者
- 4. python 生產者 --- 消費者
- 5. 消費者與生產者
- 6. kafka生產者、消費者java示例
- 7. Java生產者消費者condition實現
- 8. Java實現生產者消費者
- 9. java -12生產者和消費者
- 10. Java生產者消費者模式
- 更多相關文章...
- • 免費ARP詳解 - TCP/IP教程
- • HTTP 消息結構 - HTTP 教程
- • 適用於PHP初學者的學習線路和建議
- • 爲了進字節跳動，我精選了29道Java經典算法題，帶詳細講解
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. No provider available from registry 127.0.0.1:2181 for service com.ddbuy.ser 解決方法
- 2. Qt5.7以上調用虛擬鍵盤(支持中文)，以及源碼修改(可拖動，水平縮放)
- 3. 軟件測試面試- 購物車功能測試用例設計
- 4. ElasticSearch（概念篇）：你知道的, 爲了搜索…
- 5. redux理解
- 6. gitee創建第一個項目
- 7. 支持向量機之硬間隔（一步步推導，通俗易懂）
- 8. Mysql 異步複製延遲的原因及解決方案
- 9. 如何在運行SEPM配置嚮導時將不可認的複雜數據庫密碼改爲簡單密碼
- 10. windows系統下tftp服務器使用
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. 生產者和消費者
- 2. 生產者消費者
- 3. 生產者與消費者
- 4. python 生產者 --- 消費者
- 5. 消費者與生產者
- 6. kafka生產者、消費者java示例
- 7. Java生產者消費者condition實現
- 8. Java實現生產者消費者
- 9. java -12生產者和消費者
- 10. Java生產者消費者模式