方式 一： Synchronized方式
注：此種方式會造成資源的浪費：
利用鎖的notifyAll()方法會將所有的線程都喚醒，會造成資源的浪費

class Resource {private String name;private int count = 1;private boolean flag = false;public synchronized void set(String name) {/*對于多個生產者和消費者，為什么要用while來判斷標記？原因: 讓要被喚醒的線程再判斷一次標記，因為現在的標記可能已經不是它原來等待時的狀態了*/while (flag) { try {this.wait();} catch (Exception e) {}}this.name = name + "--" + count++;System.out.println(Thread.currentThread().getName() + "...Producer..." + this.name);this.flag = true;/*為什么要用notifyAll()因為需要喚醒對方的線程，如果只用notify()的方式有可能出現只喚醒本方線程的情況導致程序中的所有線程都處于等待的狀態下！！！*/this.notifyAll();}public synchronized void out() {while (!flag) {try {this.wait();} catch (Exception e) {}}System.out.println(Thread.currentThread().getName() + ".....Consumer....." + this.name);this.flag = false;this.notifyAll();} }class Producer implements Runnable {private Resource r;public Producer(Resource r) {this.r = r;}public void run() {while (true) {r.set("+Items+");}} }class Consumer implements Runnable {private Resource r;public Consumer(Resource r) {this.r = r;}public void run() {while (true) {r.out();}} }public class ProducerAndConsumer {public static void main(String[] args) {Resource r = new Resource();new Thread(new Producer(r)).start();new Thread(new Producer(r)).start();new Thread(new Consumer(r)).start();new Thread(new Consumer(r)).start();} }

方式二：
利用Lock的方式顯示的聲明鎖
這種方式可以人喚醒想要喚醒的線程，能夠減少資源的浪費

/*JDK1.5中提供了多線程中鎖的升級解決方案：將同步中的Synchronized替換成顯式的lock操作一個鎖可以對應多個Condition對象將object中的wait()、notify()、notifyAll()等方法替換成了Condition對象擁有的方法Condition對象通過lock鎖的newCondition()方法來獲取。不同類型的線程用不同的Condition對象來實現線程狀態的切換，以達到對不同類型的線程進行不同的操作的目的例如：下面的示例中用condition對象來對生產者的線程進行操作，用conditionPro對象來對消費者的線程進行操作，這樣就可以實現生產者的線程只喚醒消費者，消費者的線程只喚醒生產者，減少資源的浪費。即兩種類型的線程用的同一把鎖，但是用的不同的Condition對象，這樣就可以實現本方只喚醒對方的線程的操作。*/ import java.util.concurrent.locks.*;class Resource {private String name;private int count = 1;private boolean flag = false;private Lock lock = new ReentrantLock();private Condition condition = lock.newCondition();private Condition conditionPro = lock.newCondition();public void set(String name) throws InterruptedException {lock.lock();try {while (flag)condition.await();this.name = name + "--" + count++;System.out.println(Thread.currentThread().getName() + "...Producer..." + this.name);this.flag = true;conditionPro.signal();} finally {lock.unlock(); // 釋放鎖的動作一定要執行，否則會造成拋異常之后不釋放鎖，別的線程拿不到鎖}}public void out() throws InterruptedException {lock.lock();try {while (!flag)conditionPro.await();System.out.println(Thread.currentThread().getName() + ".....Consumer....." + this.name);this.flag = false;condition.signal();} finally {lock.unlock();}} }class Producer implements Runnable {private Resource r;public Producer(Resource r) {this.r = r;}public void run() {while (true) {try {r.set("+Items+");} catch (InterruptedException e) {}}} }class Consumer implements Runnable {private Resource r;public Consumer(Resource r) {this.r = r;}public void run() {while (true) {try {r.out();} catch (InterruptedException e) {}}} }public class ProducerAndConsumer {public static void main(String[] args) {Resource r = new Resource();new Thread(new Producer(r)).start();new Thread(new Producer(r)).start();new Thread(new Consumer(r)).start();new Thread(new Consumer(r)).start();} }

總結

以上是生活随笔為你收集整理的java中的生产者消费者模式详解的全部內容，希望文章能夠幫你解決所遇到的問題。

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