本篇文章为大家展示了如何在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中实现生产者消费者模式，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注亿速云行业资讯频道。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
