生產者與消費者問題：

第一步：把架子搭起來

package com.zhj.www;public class ProceduerConsumer {public static void main(String[] args) {} }//饅頭實體 class wotou{int id;wotou(int id) {this.id = id;}public String toString() {return "wotou : "+id;}} //饅頭棧 class syncStack{int index = 0;wotou[] arrWT= new wotou[6];//這個容器只能裝6個饅頭syncStack(int index) {this.index = index;}//往里仍饅頭，之所以使用synchronized關鍵字，是因為防止多個人同時往里扔，public synchronized void push(wotou wt) {arrWT[index] = wt; /*這兩行不能分開index++; */}//從里面取饅頭，拿最上面的那一個public synchronized wotou pop() {index--;return arrWT[index];}} /*多個生產者，也就是多個線程同時在執行*/ //生產者，用于對饅頭棧的引用，他需要知道生產完饅頭，需要往哪個筐里仍饅頭 class proceduer implements Runnable{syncStack ss= null;proceduer(syncStack ss) {this.ss = ss;}/*run方法對應著生產過程*/public void run() {for(int i =0;i<20;i++) {wotou wt = new wotou(i);ss.push(wt);}} } //消費者 class consumer implements Runnable{syncStack ss= null;consumer(syncStack ss) {this.ss = ss;}public void run() {for(int i =0;i<20;i++) {wotou wotou =ss.pop();System.out.println(wotou);}} }

第二步：

需要考慮當饅頭筐滿了怎么辦？馬上就會報錯？在push方法里考慮，讓這個線程休息一下;

wait方法來源于object；wait的時候這把鎖也就不屬于我了。但是sleep的時候我仍然抓住這把鎖。

package com.zhj.www;import java.io.IOException;public class ProceduerConsumer {public static void main(String[] args) {syncStack ss = new syncStack();proceduer proceduer = new proceduer(ss);consumer consumer = new consumer(ss);new Thread(proceduer).start();new Thread(consumer).start();} }//饅頭實體 class wotou{int id;wotou(int id) {this.id = id;}public String toString() {return "wotou : "+id;}} //饅頭棧 class syncStack{int index = 0;wotou[] arrWT= new wotou[6];//這個容器只能裝6個饅頭//往里仍饅頭，之所以使用synchronized關鍵字，是因為防止多個人同時往里扔，public synchronized void push(wotou wt) {if(index == arrWT.length){try {this.wait();//當前對象正在執行push方法需要wait}catch (InterruptedException e) {e.printStackTrace();}}this.notify();//哪個線程在等待就喚醒哪個線程arrWT[index] = wt; /*這兩行不能分開*/index++; }//從里面取饅頭，拿最上面的那一個public synchronized wotou pop() {if(index == 0) {try {this.wait();}catch (InterruptedException e) {e.printStackTrace();}}this.notify();//object類里的方法，喚醒一個;index--;return arrWT[index];}} /*多個生產者，也就是多個線程同時在執行*/ //生產者，用于對饅頭棧的引用，他需要知道生產完饅頭，需要往哪個筐里仍饅頭 class proceduer implements Runnable{syncStack ss= null;proceduer(syncStack ss) {this.ss = ss;}/*run方法對應著生產過程*/public void run() {for(int i =0;i<20;i++) {wotou wt = new wotou(i);ss.push(wt);System.out.println("生產了:"+wt);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} } //消費者 class consumer implements Runnable{syncStack ss= null;consumer(syncStack ss) {this.ss = ss;}public void run() {for(int i =0;i<20;i++) {wotou wotou =ss.pop();System.out.println("消費了:"+wotou);try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}} }

運行過程：

可以發現生產一個饅頭，就消耗一個饅頭。

完善之后的栗子：

package com.zhj.www;import java.io.IOException;public class ProceduerConsumer {public static void main(String[] args) {syncStack ss = new syncStack();proceduer proceduer = new proceduer(ss);consumer consumer = new consumer(ss);new Thread(proceduer).start();new Thread(consumer).start();} }//饅頭實體 class wotou{int id;wotou(int id) {this.id = id;}public String toString() {return "wotou : "+id;}} //饅頭棧 class syncStack{int index = 0;wotou[] arrWT= new wotou[6];//這個容器只能裝6個饅頭//往里仍饅頭，之所以使用synchronized關鍵字，是因為防止多個人同時往里扔，public synchronized void push(wotou wt) {while(index == arrWT.length){try {this.wait();//當前對象正在執行push方法需要wait}catch (InterruptedException e) {e.printStackTrace();}}this.notify();//哪個線程在等待就喚醒哪個線程arrWT[index] = wt; /*這兩行不能分開*/index++; }//從里面取饅頭，拿最上面的那一個public synchronized wotou pop() {while(index == 0) {try {this.wait();}catch (InterruptedException e) {e.printStackTrace();}}this.notify();//object類里的方法，喚醒一個; index--;return arrWT[index];}} /*多個生產者，也就是多個線程同時在執行*/ //生產者，用于對饅頭棧的引用，他需要知道生產完饅頭，需要往哪個筐里仍饅頭 class proceduer implements Runnable{syncStack ss= null;proceduer(syncStack ss) {this.ss = ss;}/*run方法對應著生產過程*/public void run() {for(int i =0;i<20;i++) {wotou wt = new wotou(i);ss.push(wt);System.out.println("生產了:"+wt);try {Thread.sleep((int)(Math.random()*200));} catch (InterruptedException e) {e.printStackTrace();}}} } //消費者 class consumer implements Runnable{syncStack ss= null;consumer(syncStack ss) {this.ss = ss;}public void run() {for(int i =0;i<20;i++) {wotou wotou =ss.pop();System.out.println("消費了:"+wotou);try {Thread.sleep((int)(Math.random()*1000));} catch (InterruptedException e) {e.printStackTrace();}}} }

運行之后。

總結

以上是生活随笔為你收集整理的Java 线程多线程编程3---线程同步之生产者与消费者问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。