Java實現簡易生產者消費者模型過程解析

更新時間：2020年06月03日 09:30:58 作者：main(0)

這篇文章主要介紹了Java實現簡易生產者消費者模型過程解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

一、概述

一共兩個線程，一個線程生產產品，一個線程消費產品，使用同步代碼塊方法，同步兩個線程。當產品沒有時，通知生產者生產，生產者生產后，通知消費者消費，并等待消費者消費完。

需要注意的是，有可能出現，停止生產產品后，消費者還沒未來得及消費生產者生產的最后一個產品，就結束消費，導致最后一個產品沒有被消費。

本例使用synchronize以及wait()、notify()實現簡易版的線程者消費者模型。

二、測試用例

這里的產品用筆來演示，每只筆都有其編號code

一共有四個類:分別是生產者類，產品類，消費者類，測試類

產品

package test.exception.producer_consumer_model;

/*
假設為產品為筆
 */

public class Production {
  private String type = "";
  private String color = "";
  private long code = 0; // 產品編號
  private boolean isProduced = false; // 是否生產完成 初始狀態(tài)為未生產狀態(tài)
  private boolean isContinueProduce = true; // 是否停產該產品

  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;
  }
}

生產者

package test.exception.producer_consumer_model;

public class Producer implements Runnable {
  private final Production pen; // 產品

  public Producer(Production pen) {
    this.pen = pen;
  }

  // 生產
  public void produce() {
    long code = 0;
    while (this.pen.isContinueProduce()) {
      synchronized (this.pen) {
        if (this.pen.isProduced()) {
          try {
            this.pen.wait(); // 等待消費者消費
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }
        // 開始生產
        this.pen.setType("鉛筆");
        this.pen.setColor("藍色");
        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();
  }
}

消費者

package test.exception.producer_consumer_model;

public class Consumer implements Runnable {
  private final Production pen;

  public Consumer(Production pen) {
    this.pen = pen;
  }

  // 持續(xù)消費
  public void consumer() {
    while (this.pen.isContinueProduce()) {
      synchronized (this.pen) {
        if (!this.pen.isProduced()) {
          try {
            this.pen.wait(); // 等待生產者生產
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
        }

        System.out.println(this.pen + " is consumed"); // 使用
        this.pen.setProduced(false); // 使用完后更新狀態(tài)
        this.pen.notify();
      }
    }
    // 確保停止生產后，能夠使用最后生產的一支筆
    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(); // 開啟生產者線程
    new Thread(consumer).start(); // 開啟消費者線程

    Thread.sleep(10000);
    pen.setContinueProduce(false); // 10s后停止生產該類型的筆
  }
}

運行結果

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

Java超詳細講解三大特性之一的繼承
繼承就是可以直接使用前輩的屬性和方法。自然界如果沒有繼承，那一切都是處于混沌狀態(tài)。多態(tài)是同一個行為具有多個不同表現形式或形態(tài)的能力。多態(tài)就是同一個接口，使用不同的實例而執(zhí)行不同操作
2022-05-05
Spring?Security密碼解析器PasswordEncoder自定義登錄邏輯
這篇文章主要為大家介紹了Spring?Security密碼解析器PasswordEncoder自定義登錄邏輯示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2022-08-08
Java?Map接口概述和常用方法詳解
現實生活中，我們常會看到這樣的一種集合：IP地址與主機名，身份證號與個人，系統(tǒng)用戶名與系統(tǒng)用戶對象等，這種一一對應的關系，就叫做映射。Java提供了專門的集合類用來存放這種對象關系的對象，即java.util.Map接口。本文就來聊聊Map接口概述和常用方法
2022-10-10
Java 線程池_動力節(jié)點Java學院整理
系統(tǒng)啟動一個新線程的成本是比較高的，因為它涉及到與操作系統(tǒng)的交互。在這種情況下，使用線程池可以很好的提供性能，尤其是當程序中需要創(chuàng)建大量生存期很短暫的線程時，更應該考慮使用線程池
2017-05-05
Java下界通配符(? super Type)的使用
在Java中,? super Type是一個下界通配符,本文主要介紹了Java下界通配符(? super Type)的使用,具有一定的參考價值,感興趣的可以了解一下
2024-01-01
Java動態(tài)代理的兩種實現方式詳解【附相關jar文件下載】
這篇文章主要介紹了Java動態(tài)代理的兩種實現方式,結合實例形式分析了java動態(tài)代理的相關原理、實現方法與操作技巧,并附帶相關jar文件供讀者下載,需要的朋友可以參考下
2019-03-03
開源的Java圖片處理庫實例詳解
Java?圖片處理庫提供了豐富的功能,用于處理和增強圖像,在Java生態(tài)系統(tǒng)中,有幾個流行的開源庫可以用于圖片處理,這些庫提供了豐富的功能,如圖像縮放、裁剪、顏色調整、格式轉換等,本文介紹開源的Java圖片處理庫介紹,感興趣的朋友一起看看吧
2024-03-03
SpringBoot集成EasyExcel實現Excel導入的方法
這篇文章主要介紹了SpringBoot集成EasyExcel實現Excel導入的方法,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
2021-01-01
Java的信號量semaphore講解
這篇文章主要介紹了Java的信號量semaphore講解,Semaphore底層是基于AbstractQueuedSynchronizer來實現的,Semaphore稱為計數信號量,它允許n個任務同時訪問某個資源,需要的朋友可以參考下
2023-12-12
java集合PriorityQueue優(yōu)先級隊列方法實例
這篇文章主要為大家介紹了java集合PriorityQueue優(yōu)先級隊列方法實例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
2023-12-12