软件编程
位置:首页>> 软件编程>> java编程>> Java生产者消费者模式实例分析

Java生产者消费者模式实例分析

作者:Bug开发攻城狮  发布时间:2023-12-13 02:12:59 

标签:Java,生产者消费者模式

本文实例讲述了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生产者消费者模式实例分析

希望本文所述对大家java程序设计有所帮助。

来源:https://blog.csdn.net/zy_281870667/article/details/70853474

0
投稿

猜你喜欢

手机版 软件编程 asp之家 www.aspxhome.com