一、优先队列概述 优先队列PriorityQueue是Queue接口的实现，可以对其中元素进行排序， 可以放基本数据类型的包装类（如：Integer，Long等）或自定义的类 对于基本数据类型的包装器类，优先队列中元素默认排列顺序是升序排列 但对于自己定义的类来说，需要自己定义比较器 二、常用方法peek()//返回队首元素 poll()//返回队首元素，队首元素出队列 add()//添加元素 size()//返回队列元素个数 isEmpty()//判断队列是否为空，为空返回...
java并发包中提供了三个常用的并发队列实现，分别是：ConcurrentLinkedQueue、LinkedBlockingQueue和ArrayBlockingQueue。 ConcurrentLinkedQueue使用的是CAS原语无锁队列实现，是一个异步队列，入队速度很快，出队进行了加锁，性能稍慢； LinkedBlockingQueue也是阻塞队列，入队和出队都用了加锁，当队空的时候线程会暂时阻塞；当队空的时候线程会暂时阻塞； ArrayBlockingQueue是初始容器固定的阻塞队列，我们可以用来作为数据...
@toc 和栈一样，队列也是表，但是使用队列的特点是先进先出。 队列模型 \(\color{black}{队列的基本操作是入队，它是在表的末端插入一个元素，和出队，它是删除在表开头的一个元素}\) graph LR A[<kbd>入队</kbd>] --> b[队列] b[队列] --> c[<kbd>出队</kbd>]队列的循环数组实现实现队列的类import java.util.Arrays;/*** @author 李正阳* @param <E> 泛型存储类型*/ public class MyArrayQueue<E> implements queue<E> {/*** @p...
SynchronousQueue是一个不存储元素的阻塞队列。每一个put操作必须等待一个take操作，否则不能继续添加元素。SynchronousQueue可以看成是一个传球手，负责把生产者线程处理的数据直接传递给消费者线程。队列本身并不存储任何元素，非常适合于传递性场景,比如在一个线程中使用的数据，传递给另外一个线程使用，SynchronousQueue的吞吐量高于LinkedBlockingQueue 和 ArrayBlockingQueue。
为什么要使用消息队列: 解耦 在项目启动之初来预测将来项目会碰到什么需求，是极其困难的。消息系统在处理过程中间插入了一个隐含的、基于数据的接口层，两边的处理过程都要实现这一接口。这允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。 冗余 有些情况下，处理数据的过程会失败。除非数据被持久化，否则将造成丢失。消息队列把数据进行持久化直到它们已经被完全处理，通过这一方式规避了数据丢失风...
/*** Priority queue* */ public class PriorityQ {private int mSize ;private int[] datas;private int itemIndex;public PriorityQ (int s) {mSize = s;itemIndex = -1;datas = new int[mSize];}public void insert (int item) {if (itemIndex == mSize - 1) throw new IllegalStateException("the priority is full.");if (itemIndex == -1) {datas[++itemIndex] = item;} else {for (int i = itemIndex; i >= 0; i--) {Syste...
概述java延迟队列提供了在指定时间才能获取队列元素的功能，队列头元素是最接近过期的元素。没有过期元素的话，使用poll()方法会返回null值，超时判定是通过getDelay(TimeUnit.NANOSECONDS)方法的返回值小于等于0来判断。延时队列不能存放空元素。 延时队列实现了Iterator接口，但iterator()遍历顺序不保证是元素的实际存放顺序。 队列元素DelayQueue<E extends Delayed>的队列元素需要实现Delayed接口，该接口类定义如下:publi...
众所周知，在Java的知识体系中，并发编程是非常重要的一环，也是面试的必问题，一个好的Java程序员是必须对并发编程这块有所了解的。 然而不论是哪个国家，什么背景的 Java 开发者，都对自己写的并发程序相当自信，但也会在出问题时表现得很诧异甚至一筹莫展。 可见，Java 并发编程显然不是一件能速成的能力，基础搭得越好，越全面，在实践中才会有更深刻的理解。 因此，大家不难发现 Java 并发问题一直是各个大厂面试的重点之一。...
面试题 为什么使用消息队列？消息队列有什么优点和缺点？Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么区别，以及适合哪些场景？ 面试官心理分析其实面试官主要是想看看： 第一，你知不知道你们系统里为什么要用消息队列这个东西？不少候选人，说自己项目里用了 Redis、MQ，但是其实他并不知道自己为什么要用这个东西。其实说白了，就是为了用而用，或者是别人设计的架构，他从头到尾都没思考过。没有对自己的架构问过为什么的人，...
数据结构与算法分析 表、栈、队列List接口、ArrayList类和LinkedList类 1.1 List接口继承Collection接口 public interface List<E> extends Collection<E>{E get(int index);E set(int index,E newval);void add(int index,E x);void remove(int index);ListIterator<E> listInterator(int pos);//...... }List ADT有两种流行的实现方式ArrayList 类是一种可增长数组实现。优点：对get、set 的调用花费常数时间 缺点：插入项和现有...
在新增的Concurrent包中，BlockingQueue很好的解决了多线程中，如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类，为我们快速搭建高质量的多线程程序带来极大的便利。本文详细介绍了BlockingQueue家庭中的所有成员，包括他们各自的功能以及常见使用场景。 认识BlockingQueue阻塞队列，顾名思义，首先它是一个队列，而一个队列在数据结构中所起的作用大致如下图所示： 从上图我们可以很清楚看到，通过一个共享的队...
/*** 放入数据：* offer(anObject):表示如果可能的话,将anObject加到BlockingQueue里,即如果BlockingQueue可以容纳,* 则返回true,否则返回false.（本方法不阻塞当前执行方法的线程）* offer(E o, long timeout, TimeUnit unit),可以设定等待的时间，如果在指定的时间内，还不能往队列中* 加入BlockingQueue，则返回失败。* put(anObject):把anObject加到BlockingQueue里,如果BlockQueue没有空间,则调用...
java队列 接口Queue类在java.util包，定义了以下6个方法详细查看官方文档https://docs.oracle.com/javase/7/docs/api/java/util/Queue.html 什么是阻塞队列 BlockingQueue队列是一种数据结构，它的特点是先进先出（First In First Out），它有两个基本操作：在队列尾部加入一个元素，从队列头部移除一个元素。队列在多线程应用中，常用于生产-消费场景。BlockingQueue 是 Java util.concurrent 包下重要的数据结构，BlockingQueue ...
1. 什么是阻塞队列？ 阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空；当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器里拿元素。 阻塞队列提供了四种处理方法:方法\处理方式抛出异常返回特...
1、下载安装ActiveMQ ActiveMQ官网下载地址：http://activemq.apache.org/download.htmlActiveMQ 提供了Windows 和Linux、Unix 等几个版本，楼主这里选择了Linux 版本下进行开发。 下载完安装包，解压之后的目录： 从它的目录来说，还是很简单的： bin存放的是脚本文件 conf存放的是基本配置文件 data存放的是日志文件 docs存放的是说明文档 examples存放的是简单的实例 lib存放的是activemq所需jar包 webapps用于存放项目的...