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

一、倉庫
可以選擇有線程安全的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){//容量達(dá)到20以上，等待消費(fèi)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();}}}}

三、消費(fèi)者

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("消費(fèi)掉一個產(chǎn)品--"+remove);}list.notify();}}}}

四、測試類

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

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

總結(jié)

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

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