简书 占小狼转载请注明原创出处,谢谢! 关于文章中的疑问:为什么要构造一个反序链表,放在nextTable的i+n的位置上呢,在《深入分析ConcurrentHashMap1...
![240](https://cdn2.jianshu.io/assets/default_avatar/7-0993d41a595d6ab6ef17b19496eb2f21.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
简书 占小狼转载请注明原创出处,谢谢! 关于文章中的疑问:为什么要构造一个反序链表,放在nextTable的i+n的位置上呢,在《深入分析ConcurrentHashMap1...
是所有level的任务公用一个timer,也就是说一个线程处理所有的延迟任务
rocketmq实现延时队列说明:rocketmq实现的延时队列只支持特定的延时时间段,1s,5s,10s,...2h,不能支持任意时间段的延时 具体实现:rocketmq发送延时消息时先把消息按照延迟...
题目 已知 sqrt (2)约等于 1.414,要求不用数学库,求 sqrt (2)精确到小数点后 10 位 考察点 基础算法的灵活应用能力,二分法学过数据结构的同学都知道,...
输入一批区间,输出合并后的区间 示例: 输入: [[1,3],[2,6],[8,10],[15,18]] 输出: [[1,6],[8,10],[15,18]] 解释: 区间 ...
题目描述:采用二分查找获取树中第K大的元素 算法描述:二叉查找树按照中序遍历后,可以使得遍历后的元素有序,可以借助这一个特性来实现,二叉查找树遍历可以根据递归遍历,也可以借助...
使用内部类实现懒加载模型的单例
手写java版快速排序算法实现
sleep是Thread持有的方法,而wait是Object类持有的对象; sleep在持有锁的过程中不会释放锁,而wait在持有锁的过程中会释放锁; 实验代码: 分别注释掉...
在工作中想实现一个延迟功能,一般会借助rocketmq或者kafka的延迟队列功能来实现,但是这俩个消息中间件都有一个弊端,就是很难支持任意时间段的延迟,所以我想借助redi...
说明:rocketmq实现的延时队列只支持特定的延时时间段,1s,5s,10s,...2h,不能支持任意时间段的延时 具体实现:rocketmq发送延时消息时先把消息按照延迟...
rocketmq 消费消息大致有以下几种场景类型 乱序消费,消息被乱序的发送的队列,消费者在消费各个队列时是并行消费,所以不能保证消息的有序性 顺序消息,发送到同一个队列的消...
用过rocketmq的童靴们肯定知道,它的延迟消息的时间不是任意时间片,而是仅支持18个固定的时间段,默认的配置是messageDelayLevel=1s 5s 10s 30...
附一张java成神的思维导图
rocketmq的producer发送消息,大致会分为如下几种消息 同步消息,发送者必须同步等待; 异步消息,消息发送成功,异步通知; 单向消息,消息直接发送,不管成功失败;...
rocketmq整体包含4个模块 1 nameServer 命名服务器,类似zk2 broker 代理服务器,存储消息3 producer 消息发送者4 consumer 消...
rocketmq整体发送流程图如下 从上图中可以看出broker端内部是分为很多个具体的队列,producer发送的时候均匀的发送到所有的队列,而consumer是平均的消费...
JUC提供了java并发编程需要的类,主要分几个大模块1 原子类操作2 锁3 阻塞队列4 并发集合5 同步器6 线程池7异步组合编程 JUC的作者Doug Lea神一样的人物...
disruptor是一个高性能的内存队列,之所以高性能,因为有以下几个特点: 1 整个disruptor的实现在并发处理中没有使用锁,而是使用的cas操作(disruptor...