Java多線程生產(chǎn)者消費者模式實現(xiàn)過程解析

單生產(chǎn)者與單消費者

成都創(chuàng)新互聯(lián)是一家專業(yè)從事成都網(wǎng)站設(shè)計、網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司。作為專業(yè)網(wǎng)站制作公司,成都創(chuàng)新互聯(lián)依托的技術(shù)實力、以及多年的網(wǎng)站運營經(jīng)驗,為您提供專業(yè)的成都網(wǎng)站建設(shè)、全網(wǎng)營銷推廣及網(wǎng)站設(shè)計開發(fā)服務(wù)！

示例：

public class ProduceConsume {
    public static void main(String[] args) {
      String lock = new String("");
      Produce produce = new Produce(lock);
      Consume consume = new Consume(lock);

      new Thread(() -> {
        while (true) {
          produce.setValue();
        }
      }, "ProductThread").start();
      new Thread(() -> {
        while (true) {
          consume.getValue();
        }
      }, "ConsumeThread").start();
    }

    /**
     * 生產(chǎn)者
     */
    static class Produce {
      private String lock;

      public Produce(String lock) {
        this.lock = lock;
      }

      public void setValue() {
        try {
          synchronized (lock) {
            if (!ValueObject.value.equals("")) {
              lock.wait();
            }
            String value = System.currentTimeMillis() + "_" + System.nanoTime();
            System.out.println("set的值是" + value);
            ValueObject.value = value;
            lock.notify();
          }
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    }

    /**
     * 消費者
     */
    static class Consume {
      private String lock;

      public Consume(String lock) {
        this.lock = lock;
      }

      public void getValue() {
        try {
          synchronized (lock) {
            if (ValueObject.value.equals("")) {
              lock.wait();
            }
            System.out.println("get的值是" + ValueObject.value);
            ValueObject.value = "";
            lock.notify();
          }
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
    }

    static class ValueObject {
      public static String value = "";
    }
}

執(zhí)行結(jié)果如下：

Java多線程生產(chǎn)者消費者模式實現(xiàn)過程解析

多生產(chǎn)者與多消費者

這種模式下，容易出現(xiàn)“假死”，也就是全部線程都進(jìn)入了 WAITNG 狀態(tài)，程序不在執(zhí)行任何業(yè)務(wù)功能了，整個項目呈停止?fàn)顟B(tài)。

示例：

public class MultiProduceConsume {
  public static void main(String[] args) throws InterruptedException {
    String lock = new String("");
    Produce produce = new Produce(lock);
    Consume consume = new Consume(lock);
    Thread[] pThread = new Thread[2];
    Thread[] cThread = new Thread[2];
    for (int i = 0; i < 2; i++) {
      pThread[i] = new Thread(() -> {
        while (true) {
          produce.setValue();
        }
      }, "生產(chǎn)者" + (i + 1));

      cThread[i] = new Thread(() -> {
        while (true) {
          consume.getValue();
        }
      }, "消費者" + (i + 1));
      pThread[i].start();
      cThread[i].start();
    }

    Thread.sleep(5000);
    Thread[] threadArray = new Thread[Thread.currentThread().getThreadGroup().activeCount()];
    Thread.currentThread().getThreadGroup().enumerate(threadArray);
    for (int i = 0; i < threadArray.length; i++) {
      System.out.println(threadArray[i].getName() + " " + threadArray[i].getState());
    }
  }

  static class Produce {
    private String lock;

    public Produce(String lock) {
      this.lock = lock;
    }

    public void setValue() {
      try {
        synchronized (lock) {
          while(!ValueObject.value.equals("")) {
            System.out.println("生產(chǎn)者 " + Thread.currentThread().getName() + " WAITING了⭐");
            lock.wait();
          }
          System.out.println("生產(chǎn)者 " + Thread.currentThread().getName() + " RUNNABLE了");
          String value = System.currentTimeMillis() + "_" + System.nanoTime();
          ValueObject.value = value;
          lock.notify();
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }

  static class Consume {
    private String lock;

    public Consume(String lock) {
      this.lock = lock;
    }

    public void getValue() {
      try {
        synchronized (lock) {
          while (ValueObject.value.equals("")) {
            System.out.println("消費者 " + Thread.currentThread().getName() + " WAITING了⭐");
            lock.wait();
          }
          System.out.println("消費者 " + Thread.currentThread().getName() + "RUNNABLE了");
          ValueObject.value = "";
          lock.notify();
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }

  static class ValueObject {
    public static String value = "";
  }
}

運行結(jié)果如圖：

Java多線程生產(chǎn)者消費者模式實現(xiàn)過程解析

分析：

雖然代碼中通過 wait/notify 進(jìn)行通信了，但是不能保證 notify 喚醒的一定是異類，也可能是同類，比如“生產(chǎn)者”喚醒了“生產(chǎn)者”這樣的情況。

解決方案：

假死出現(xiàn)的主要原因是有可能連續(xù)喚醒了同類。所以解決方案很簡單，就是把 notify() 改為 notifyAll() 即可。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持創(chuàng)新互聯(lián)。

本文名稱：Java多線程生產(chǎn)者消費者模式實現(xiàn)過程解析
網(wǎng)頁鏈接：http://chinadenli.net/article30/gsgspo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)建站、品牌網(wǎng)站建設(shè)、小程序開發(fā)、網(wǎng)站設(shè)計、手機(jī)網(wǎng)站建設(shè)、搜索引擎優(yōu)化

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容

欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

Java多線程生產(chǎn)者消費者模式實現(xiàn)過程解析