這篇文章主要介紹“Java多線程生產(chǎn)者消費者模型實例代碼”，在日常操作中，相信很多人在Java多線程生產(chǎn)者消費者模型實例代碼問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”Java多線程生產(chǎn)者消費者模型實例代碼”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！

創(chuàng)新互聯(lián)建站專注于西湖企業(yè)網(wǎng)站建設,響應式網(wǎng)站,商城網(wǎng)站開發(fā)。西湖網(wǎng)站建設公司,為西湖等地區(qū)提供建站服務。全流程按需定制設計，專業(yè)設計，全程項目跟蹤，創(chuàng)新互聯(lián)建站專業(yè)和態(tài)度為您提供的服務

生產(chǎn)者消費者模型

生產(chǎn)者：生產(chǎn)任務的個體；

消費者：消費任務的個體；

緩沖區(qū)：是生產(chǎn)者和消費者之間的媒介，對生產(chǎn)者和消費者解耦。

當

緩沖區(qū)元素為滿，生產(chǎn)者無法生產(chǎn)，消費者繼續(xù)消費；

緩沖區(qū)元素為空，消費者無法消費，生產(chǎn)者繼續(xù)生產(chǎn)；

wait()/notify()生產(chǎn)者消費者模型

制作一個簡單的緩沖區(qū)ValueObject，value為空表示緩沖區(qū)為空，value不為空表示緩沖區(qū)滿

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

生產(chǎn)者，緩沖區(qū)滿則wait()，不再生產(chǎn)，等待消費者notify()，緩沖區(qū)為空則開始生產(chǎn)

public class Producer {  private Object lock;  public Producer(Object 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();    }  }}

消費者，緩沖區(qū)為空則wait(),等待生產(chǎn)者notify(),緩沖區(qū)為滿，消費者開始消費

public class Customer {  private Object lock;  public Customer(Object 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();    }  }}

main方法，啟動一個生產(chǎn)者和一個消費者

public class Main {  public static void main(String[] args)  {    Object lock = new Object();    final Producer producer = new Producer(lock);    final Customer customer = new Customer(lock);    Runnable producerRunnable = new Runnable()    {      public void run()      {        while (true)        {          producer.setValue();        }      }    };    Runnable customerRunnable = new Runnable()    {      public void run()      {        while (true)        {          customer.getValue();        }      }    };    Thread producerThread = new Thread(producerRunnable);    Thread CustomerThread = new Thread(customerRunnable);    producerThread.start();    CustomerThread.start();  }}

運行結果如下

Set的值是：1564733938518_27520480474279Get的值是：1564733938518_27520480474279Set的值是：1564733938518_27520480498378Get的值是：1564733938518_27520480498378Set的值是：1564733938518_27520480540254Get的值是：1564733938518_27520480540254······

生產(chǎn)者和消費者交替運行，生產(chǎn)者生產(chǎn)一個字符串，緩沖區(qū)為滿，消費者消費一個字符串，緩沖區(qū)為空，循環(huán)往復，滿足生產(chǎn)者/消費者模型。

await()/signal()生產(chǎn)者/消費者模型

緩沖區(qū)

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

ThreadDomain48繼承ReentrantLock，set方法生產(chǎn)，get方法消費

public class ThreadDomain48 extends ReentrantLock{  private Condition condition = newCondition();  public void set()  {    try    {      lock();      while (!"".equals(ValueObject.value))        condition.await();      ValueObject.value = "123";      System.out.println(Thread.currentThread().getName() + "生產(chǎn)了value, value的當前值是" + ValueObject.value);      condition.signal();    }    catch (InterruptedException e)    {      e.printStackTrace();    }    finally    {      unlock();    }  }  public void get()  {    try    {      lock();      while ("".equals(ValueObject.value))        condition.await();      ValueObject.value = "";      System.out.println(Thread.currentThread().getName() + "消費了value, value的當前值是" + ValueObject.value);      condition.signal();    }    catch (InterruptedException e)    {      e.printStackTrace();    }    finally    {      unlock();    }  }}

MyThread41啟動兩個生產(chǎn)線程和一個消費線程

public class MyThread41 {  public static void main(String[] args)  {    final ThreadDomain48 td = new ThreadDomain48();    Runnable producerRunnable = new Runnable()    {      public void run()      {        for (int i = 0; i < Integer.MAX_VALUE; i++)          td.set();      }    };    Runnable customerRunnable = new Runnable()    {      public void run()      {        for (int i = 0; i < Integer.MAX_VALUE; i++)          td.get();      }    };    Thread ProducerThread1 = new Thread(producerRunnable);    ProducerThread1.setName("Producer1");    Thread ProducerThread2 = new Thread(producerRunnable);    ProducerThread2.setName("Producer2");    Thread ConsumerThread = new Thread(customerRunnable);    ConsumerThread.setName("Consumer");    ProducerThread1.start();    ProducerThread2.start();    ConsumerThread.start();  }}

輸出結果如下

Producer1生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer1生產(chǎn)了value, value的當前值是123

為什么Producer2無法生產(chǎn)，消費者無法消費呢？是因為此時緩沖區(qū)為滿，Producer1的notify()應該喚醒Consumer卻喚醒了Producer2，導致Producer2因為緩沖區(qū)為滿和Consumer沒有被喚醒而處于waiting狀態(tài)，此時三個線程均在等待，出現(xiàn)了假死。

解決方案有兩種：

1.讓生產(chǎn)者喚醒所有線程，在set方法中使用condition.signalAll()；

2.使用兩個Condition，生產(chǎn)者Condition和消費者Condition，喚醒指定的線程；

正常輸入如下:

······Producer2生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer2生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer2生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer1生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer1生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer1生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer1生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是Producer1生產(chǎn)了value, value的當前值是123Consumer消費了value, value的當前值是······

到此，關于“Java多線程生產(chǎn)者消費者模型實例代碼”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關知識，請繼續(xù)關注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>

分享題目：Java多線程生產(chǎn)者消費者模型實例代碼
當前鏈接：http://www.rwnh.cn/article42/psjdhc.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供App設計、網(wǎng)站建設、企業(yè)建站、自適應網(wǎng)站、建站公司、網(wǎng)站維護

廣告

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