java多線程之消費(fèi)者生產(chǎn)者模式

1、java多線程之消費(fèi)者生產(chǎn)者模式/*author shijin* 生產(chǎn)者與消費(fèi)者模型中,要保證以下幾點(diǎn):* 1 同一時(shí)間內(nèi)只能有一個(gè)生產(chǎn)者生產(chǎn)生產(chǎn)方法加鎖sychronized * 2 同一時(shí)間內(nèi)只能有一個(gè)消費(fèi)者消費(fèi)消費(fèi)方法加鎖sychronized * 3 生產(chǎn)者生產(chǎn)的同時(shí)消費(fèi)者不能消費(fèi)生產(chǎn)方法加鎖sychronized * 4 消費(fèi)者消費(fèi)的同時(shí)生產(chǎn)者不能生產(chǎn)消費(fèi)方法加鎖sychronized * 5 共享空間空時(shí)消費(fèi)者不能繼續(xù)消費(fèi)消費(fèi)前循環(huán)判斷是否為空,空的話將該線程wait,釋放鎖允許其他同步方法執(zhí)行* 6 共享空間滿時(shí)生產(chǎn)者不能繼續(xù)生產(chǎn)生產(chǎn)前循環(huán)判斷是否為滿,滿的話將該線程wait,釋

2、放鎖允許其他同步方法執(zhí)行*/主類(lèi)class ProducerConsumerpublic static void main(String argsStackBasket s = new StackBasket(;Producer p = new Producer(s;Consumer c = new Consumer(s;Thread tp = new Thread(p;Thread tc = new Thread(c;tp.start(;tc.start(;/class Mantouprivate int id;Mantou(int idthis.id = id;public String

3、toString(return "Mantou :" + id;/共享?xiàng)？臻gclass StackBasketMantou sm = new Mantou6;int index = 0;/* show 生產(chǎn)方法.* show 該方法為同步方法,持有方法鎖;* show 首先循環(huán)判斷滿否,滿的話使該線程等待,釋放同步方法鎖,允許消費(fèi);* show 當(dāng)不滿時(shí)首先喚醒正在等待的消費(fèi)方法,但是也只能讓其進(jìn)入就緒狀態(tài),* show 等生產(chǎn)結(jié)束釋放同步方法鎖后消費(fèi)才能持有該鎖進(jìn)行消費(fèi)* param m 元素* return 沒(méi)有返回值*/public synchronized void

4、 push(Mantou mtrywhile(index = sm.length了!"this.wait(;this.notify(;catch(InterruptedException ee.printStackTrace(;catch(IllegalMonitorStateException ee.printStackTrace(;smindex = m;index+;/* show 消費(fèi)方法* show 該方法為同步方法,持有方法鎖* show 首先循環(huán)判斷空否,空的話使該線程等待,釋放同步方法鎖,允許生產(chǎn);* show 當(dāng)不空時(shí)首先喚醒正在等待的生產(chǎn)方法,但是也只能讓其進(jìn)入就

5、緒狀態(tài)* show 等消費(fèi)結(jié)束釋放同步方法鎖后生產(chǎn)才能持有該鎖進(jìn)行生產(chǎn)* param b true 表示顯示,false 表示隱藏* return 沒(méi)有返回值*/public synchronized Mantou pop(trywhile(index = 0了!"this.wait(;this.notify(;catch(InterruptedException ee.printStackTrace(;catch(IllegalMonitorStateException ee.printStackTrace(;index-;return smindex;class Producer

6、 implements RunnableStackBasket ss = new StackBasket(;Producer(StackBasket ssthis.ss = ss;/* show 生產(chǎn)進(jìn)程.*/public void run(for(int i = 0;i < 20;i+Mantou m = new Mantou(i;ss.push(m;/ 在上面一行進(jìn)行測(cè)試是不妥的,對(duì)index的訪問(wèn)應(yīng)該在原子操作里,因?yàn)榭赡茉趐ush之后此輸出之前又消費(fèi)了,會(huì)產(chǎn)生輸出混亂tryThread.sleep(int(Math.random(*500;catch(InterruptedException ee.printStackTrace(;class Co