Java生產(chǎn)者消費者模式實例分析

2024-07-14 08:43:54

字體：大中小

來源：轉(zhuǎn)載

供稿：網(wǎng)友

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

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

這么做有什么好處呢？

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

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

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

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

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

/** * *我是緩存，負責產(chǎn)品的存(生產(chǎn)后的放置)取(消費時的獲取) */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消費");  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,生產(chǎn)者,消費者模式