快捷導(dǎo)航

Java實(shí)現(xiàn)簡(jiǎn)易生產(chǎn)者消費(fèi)者模型過(guò)程解析

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

這篇文章主要介紹了Java實(shí)現(xiàn)簡(jiǎn)易生產(chǎn)者消費(fèi)者模型過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

一、概述

一共兩個(gè)線程，一個(gè)線程生產(chǎn)產(chǎn)品，一個(gè)線程消費(fèi)產(chǎn)品，使用同步代碼塊方法，同步兩個(gè)線程。當(dāng)產(chǎn)品沒(méi)有時(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)者還沒(méi)未來(lái)得及消費(fèi)生產(chǎn)者生產(chǎn)的最后一個(gè)產(chǎn)品，就結(jié)束消費(fèi)，導(dǎo)致最后一個(gè)產(chǎn)品沒(méi)有被消費(fèi)。

本例使用synchronize以及wait()、notify()實(shí)現(xiàn)簡(jiǎn)易版的線程者消費(fèi)者模型。

二、測(cè)試用例

這里的產(chǎn)品用筆來(lái)演示，每只筆都有其編號(hào)code

一共有四個(gè)類:分別是生產(chǎn)者類，產(chǎn)品類，消費(fèi)者類，測(cè)試類

產(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)品編號(hào)
  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();
          }
        }
        // 開(kāi)始生產(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īng)顟B(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();
  }
}

主線程測(cè)試

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(); // 開(kāi)啟生產(chǎn)者線程
    new Thread(consumer).start(); // 開(kāi)啟消費(fèi)者線程

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

運(yùn)行結(jié)果