Java生產(chǎn)者消費(fèi)者模式實(shí)例分析

更新時(shí)間：2019年03月08日 11:35:08 作者：Bug開發(fā)攻城獅

這篇文章主要介紹了Java生產(chǎn)者消費(fèi)者模式,結(jié)合實(shí)例形式分析了java生產(chǎn)者消費(fèi)者模式的相關(guān)組成、原理及實(shí)現(xiàn)方法,需要的朋友可以參考下

本文實(shí)例講述了Java生產(chǎn)者消費(fèi)者模式。分享給大家供大家參考，具體如下：

java的生產(chǎn)者消費(fèi)者模式，有三個(gè)部分組成，一個(gè)是生產(chǎn)者，一個(gè)是消費(fèi)者，一個(gè)是緩存。

這么做有什么好處呢？

1.解耦(去依賴)，如果是消費(fèi)者直接調(diào)用生產(chǎn)者，那如果生產(chǎn)者的代碼變動(dòng)了，消費(fèi)者的代碼也需要隨之變動(dòng)

2.高效，如果消費(fèi)者直接掉生產(chǎn)者，執(zhí)行時(shí)間較長的話，會(huì)阻塞，影響其他業(yè)務(wù)的進(jìn)行

3.負(fù)載均衡，如果消費(fèi)者直接調(diào)生產(chǎn)者，那生產(chǎn)者和消費(fèi)者就得在一起了，日后業(yè)務(wù)量非常大的話，要想減輕服務(wù)器的壓力，想拆分生產(chǎn)和消費(fèi)，就很困難

/**
 * 我是生產(chǎn)者，負(fù)責(zé)生產(chǎn)
 */
public class Product implements Runnable {
 private Queue q;
 public Product(Queue q) {
 this.q = q;
 }
 @Override
 public void run() {
 try {
  for (int i = 0; i < 3; i++) {
  q.product("test" + i);
  }
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 }
}

/**
 *我是消費(fèi)者，負(fù)責(zé)消費(fèi)
 */
public class Consumer implements Runnable {
 private Queue q;
 public Consumer(Queue q){
 this.q = q;
 }
 @Override
 public void run() {
 try {
  for(int i=0 ; i < 3 ; i++){
  q.consumer();
  }
 } catch (InterruptedException e) {
  e.printStackTrace();
 }
 }
}

/**
 *
 *我是緩存，負(fù)責(zé)產(chǎn)品的存(生產(chǎn)后的放置)取(消費(fèi)時(shí)的獲取)
 */
public class Queue {
 private final Object lock = new Object();
 private List<String> list = new ArrayList<String>();
 public void product(String param) throws InterruptedException {
 synchronized (lock) {
  System.out.println("product生產(chǎn)");
  list.add(param);
  lock.notify();
  lock.wait();
 }
 }
 public void consumer() throws InterruptedException {
 synchronized (lock) {
  lock.wait();
  System.out.println("product消費(fèi)");
  if (list.size() > 0) {
  list.remove(list.size() - 1);
  }
  lock.notify();
 }
 }
}
public class TestMain {
 public static void main(String[] args) {
 Queue q = new Queue();
 Product p = new Product(q);
 Consumer s = new Consumer(q);
 Thread t1 = new Thread(p);
 Thread t2 = new Thread(s);
 t1.start();
 t2.start();
 }
}