如何在Java中实现生产者消费者模式

发布时间:2021-06-08 17:26:31 作者:Leah
来源:亿速云 阅读:112

本篇文章为大家展示了如何在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中实现生产者消费者模式,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注亿速云行业资讯频道。

推荐阅读:
  1. java 多线程-生产者消费者模式-管程法
  2. Java如何实现Kafka生产者消费者

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

java

上一篇:如何在Java中使用POI读取和写入Excel

下一篇:使用易语言怎么实现显示和隐藏控制按钮功能

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》