分布式消息队列（MQ） 场景服务解耦 削峰填谷 异步化缓冲：最终一致性/柔性事务MQ应用思考点生产端可靠性投递 消费端幂等：消息只能消费一次 高可用、低延迟、可靠性 消息堆积能力 可扩展性业界主流MQActiveMQ：适合传统需求，并发性差 RabbitMQ：扩展性差 RocketMQ：扩展性强 Kafka：扩展性强，并发性强，可靠性差技术选型性能、优缺点、业务场景 集群架构模式，分布式、可扩展、高可用、可维护性 综合成本，集群规模，人员成本 未...
PriorityQueue是Java内置的优先队列，每次取出来的元素是最小的。PriorityQueue可以做到自动扩容。PriorityQueue中的对象必须是可比较的。 例如，最简单的情况，在PriorityQueue中保存整数：PriorityQueue<Integer> priInt = new PriorityQueue<>();然后在其中依次添加五个整数（注意，在PriorityQueue中添加对象，可以调用add，也可以调用offer。）priInt.add(1); priInt.add(3); priInt.add(4); priInt.add(5); priInt.add...
从源码学习Java并发的锁是怎么维护内部线程队列的在上一篇文章中，凯哥对同步组件基础框架- AbstractQueuedSynchronizer(AQS)做了大概的介绍。我们知道AQS能够通过内置的FIFO队列来完成资源获取线程的排队工作。那么AQS是怎么来维护这个排队工作的呢？今天我们就来扒一扒AQS源码。从源码中来看看是怎么维护对了的。本篇是《凯哥(凯哥Java:kagejava)并发编程学习》系列之《Lock系列》教程的第一篇：《Java并发包下锁学习第三篇-从源...
Java并发包下锁学习第二篇队列同步器还记得在第一篇文章中，讲到的locks包下的类结果图吗？如下图：从图中，我们可以看到AbstractQueuedSynchronizer这个类很重要(在本文中，凯哥就用AQS来代替这个类)。我们先来了解这个类。对这个类了解之后，学习后面的会更容易了。本篇是《凯哥(凯哥Java:kagejava)并发编程学习》系列之《Lock系列》教程的第一篇：《Java并发包下锁学习第二篇：队列同步器》。本文主要内容：同步器介绍；同步器和...
目录1.LinkedBlockingQueue介绍 ? ? 1.1BlockingQueue接口 ? ? 1.2LinkedBlockingQueue ? ? 1.3LinkedBlockingQueue原理与数据结构 2.LinkedBlockingQueue源码分析 ? ? 2.1创建 ? ? 2.2put方法 ? ? 2.3take方法1.LinkedBlockingQueue介绍1.1BlockingQueue接口 同ArrayBlockingQueue一样，LinkedBlockingQueue同样实现了BlockingQueue接口。 1.2LinkedBlockingQueueLinkedBlockingQueueLinkedBlockingQueue是一个单向链表实现的阻塞...
消息队列面试题 题目来自于中华石杉，解决方案根据自己的思路来总结而得。题目主要如下： 1. 为什么要引入消息队列? 消息队列的引入可以解决3个核心问题：解耦 异步 削峰解耦在一个项目中，如果一个模块A产生的一个关键数据，需要调用其他模块接口服务；而需要调用的接口很多，又不确定之后是否还需要将数据传给其他模块的接口时。这时可以使用消息队列，使用了消息队列之后，模块A不需...
整个的体系图悲观锁，乐观锁 是一个广义概念；体现的是看待线程同步的不同角度。 悲观锁 认为在自己使用数据的时候一定有别的线程来修改数据，在获取数据的时候会先加锁，确保数据不被别的线程修改。 实现：关键字synchronized,接口Lock的实现类 适用场景：写操作多，先加锁可以保证写操作时的数据正确。 乐观锁 认为自己在使用数据的时候不会有别的线程修改数据，所以不会添加锁，只是在更新数据的时候去判断之前有没有别的线程更...
有很多原因导致你应在程序中使用内部队列。抽丝剥茧，细说架构那些事——【优锐课】在程序中使用内部队列有很多充分的理由。大多数常见模式都包含相同的原理-将处理分为两个独立的部分，然后每个部分都可以自主工作。队列是将对象从一个线程转移到另一个线程并确保属于特定转移对象的所有字段的正确可见性的最佳方法。这种常见的模式称为“消费者-生产者”模式。但是，今天，优锐课想更多地关注潜在的故障，监视以及如何避免程序中...
java.util.concurrent包中的BlockingQueue接口通常用于一个线程生产对象，而另一个线程消费这些对象的场景。 一个线程将会持续生产新对象并将其插入队列中，知道队列达到所能容纳的临界点。也就是说，队列是有限的。如果该阻塞队列到达了其临界点，负责生产的线程将会发生阻塞，且一直处于阻塞状态中，直到负责消费的线程从队列中拿走一个对象。负责消费的线程会一直从阻塞队列中拿出对象。如果消费线程尝试从一个空队列中提取对象...
优先队列（底层结构为最大堆） 普通的队列是一种先进先出的数据结构，元素在队列尾追加，而从队列头删除。在优先队列中，元素被赋予优先级。当访问元素时，具有最高优先级的元素最先删除。优先队列具有最高级先出 （first in, largest out）的行为特征。通常采用堆数据结构来实现。 优先队列主要是出队操作与普通队列不同，队列中元素会有优先级之分，每次出队的元素是优先级最高的元素。 最大堆（二叉堆） 最大堆是堆的两种形式之...
题目链接 https://leetcode-cn.com/problems/implement-queue-using-stacks/ 题目描述 使用栈实现队列的下列操作： push(x)?--?将一个元素放入队列的尾部。pop()?--?从队列首部移除元素。peek()?--?返回队列首部的元素。empty()?--?返回队列是否为空。 示例： MyQueue queue = new MyQueue();queue.push(1);queue.push(2); queue.peek(); // 返回 1queue.pop(); // 返回 1queue.empty(); // 返回 false 思路 使用两个栈来完成操...
阻塞队列各实现类类 说明ArrayBlockingQueue 由数组结构组成的有界阻塞队列LinkedBlockingQueue 由链表结构组成的有界阻塞队列（默认容量为Integer.MAX_VALUE）PriorityBlockingQueue 支持优先级排序的无界阻塞队列DelayQueue 使用优先级队列实现的延迟无界阻塞队列SynchronousQueue 不存储元素的阻塞队列，也即单个元素的队列LinkedTransferQueue 由链表结构组成的无界阻塞队列LinkedBlockingQueue 由链表结构组成的双向阻塞队列阻...
import java.util.Iterator; public class Deque<Item> implements Iterable<Item> {private class Node {Item item;Node next;Node pre;}private class QueueIterator implements Iterator<Item> {public boolean hasNext() {return current != null;}public Item next() {Item tmp = current.item;current = current.next;return tmp;}private Node current = front;}public Iterator<Item> iterator() {return new QueueIterato...
队列同步器（AQS） 队列同步器AbstractQueuedSynchronizer（以下简称同步器），是用来构建锁或者其他同步组件的基础框架，它使用了一个int成员变量表示同步状态，通过内置的FIFO队列来完成资源获取线程的排队工作。 同步器的主要使用方式是继承，子类通过继承同步器并实现它的抽象方法来管理同步状态，在抽象方法的实现过程中免不了要对同步状态进行更改，这时就需要使用同步器提供的3个方法（getState()、setState(int newState)和...