Java生產者消費者模式實例分析

2024-07-14 08:43:54

字體：大中小

來源：轉載

供稿：網友

本文實例講述了Java生產者消費者模式。分享給大家供大家參考，具體如下：

java的生產者消費者模式，有三個部分組成，一個是生產者，一個是消費者，一個是緩存。

這么做有什么好處呢？

1.解耦(去依賴)，如果是消費者直接調用生產者，那如果生產者的代碼變動了，消費者的代碼也需要隨之變動

2.高效，如果消費者直接掉生產者，執行時間較長的話，會阻塞，影響其他業務的進行

3.負載均衡，如果消費者直接調生產者，那生產者和消費者就得在一起了，日后業務量非常大的話，要想減輕服務器的壓力，想拆分生產和消費，就很困難

/** * 我是生產者，負責生產 */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(); } }}

/** *我是消費者，負責消費 */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(); } }}

/** * *我是緩存，負責產品的存(生產后的放置)取(消費時的獲取) */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生產");  list.add(param);  lock.notify();  lock.wait(); } } public void consumer() throws InterruptedException { synchronized (lock) {  lock.wait();  System.out.println("product消費");  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(); }}

Java,生產者,消費者模式