Java多線程生產(chǎn)者與消費者，準確說應該是“生產(chǎn)者-消費者-倉儲”模型，使用了倉儲，使得生產(chǎn)者消費者模型就顯得更有說服力。
對于此模型，應該明確一下幾點：
1、生產(chǎn)者僅僅在倉儲未滿時候生產(chǎn)，倉滿則停止生產(chǎn)。
2、消費者僅僅在倉儲有產(chǎn)品時候才能消費，倉空則等待。
3、當消費者發(fā)現(xiàn)倉儲沒產(chǎn)品可消費時候會通知生產(chǎn)者生產(chǎn)。
4、生產(chǎn)者在生產(chǎn)出可消費產(chǎn)品時候，應該通知等待的消費者去消費。

一、倉庫
可以選擇有線程安全的PriorityBlockingQueue也可以使用普通的list，為了更加體現(xiàn)多線程這里使用沒有線程安全的普通list

private static LinkedList<String> list = new LinkedList<String>();

使用LinkedList是因為刪除時更加方便。
二、生產(chǎn)者

/*** 生產(chǎn)者* * @author Administrator* */static class ProductThread implements Runnable {private int count = 0;public ProductThread(int count) {this.count = count;}@Overridepublic void run() {while(true){synchronized (list) {if(list.size()>20){//容量達到20以上，等待消費try {list.wait();} catch (InterruptedException e) {e.printStackTrace();}}for(int i = 1;i<count ;i++){System.out.println("生產(chǎn)了一個產(chǎn)品---"+i);list.add("str"+i);}list.notifyAll();}}}}

三、消費者

static class CustomerThread implements Runnable {private int count = 0;public CustomerThread(int count) {this.count = count;}@Overridepublic void run() {while(true){synchronized (list) {if(list.size() < count){System.out.println("容器中數(shù)量不夠，" + list.size());try {list.wait();// 等待} catch (Exception e) {e.printStackTrace();}}for(int i =1;i<=count;i++){String remove = list.remove();System.out.println("消費掉一個產(chǎn)品--"+remove);}list.notify();}}}}

四、測試類

public static void main(String[] args) {// 每次生產(chǎn)10個Thread proTh = new Thread(new ProductThread(10));// 每次消費6個Thread cusTh = new Thread(new CustomerThread(6));proTh.start();cusTh.start();}

這樣一個簡單的生產(chǎn)者消費者模型就完成了。

總結

以上是生活随笔為你收集整理的Java多线程-生产者与消费者的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。