队列管理在上一篇文章(NVMe系列专题之一：NVMe技术概述)中，我们提到了NVMe有一个很大的优势就是队列深度达到了64K，并且支持队列个数最大可达64K。所以呢，这里我们就先聊聊NVMe中队列相关的一些知识点。队列，在NVMe协议中，是专门为NVMe命令服务的。介绍队列之前，我们还是先看看NVMe定义的命令种类：NVMe定义的命令很简单，只有两种: Ad …
优先队列
业务背景在平时的业务中我们可能会碰到这样的需求，用户A将任务分配给用户B，如果30天后用户B还没有处理这个任务，那么系统自动将这个任务转发给用户C，或者将任务退回给任务A。这里我们就可以使用延迟队列，我们写好转发方法或者退回方法，用户A分配任务时将时间记录放入延迟队列。当30天后用户B没有处理，我们获取从延迟队列里面获取这个记录，能获取得到，就执行转发方法或 …
l 消息队列在Linux IPC中一种很常见的通信方式，本人主要在线程间通信之间使用消息队列，l 消息队列在理解上可认为是一种链表，线程可以往该消息队列写消息，同时也可以取出消息，当时使用消息队列前必须前初始化一个消息队列，也就是创建一个消息队列。l 消息队列的接收函数mq_receive(),该函数的第三个参数是读取消息的长度；l 消息的优先级，该值小于M …
然后我们再来看,可以看到default队列我们要陪着,他占用总内存的百分之40,然后最大资源容量占用总资源的百分之60,然后我们再添加一个队列,hive队列,然后让这个hive队列占用总内存的百分之60,然后最大资源容量占用总资源的百分之80然后我们去看一下后台这个scheduler中可以看到有个default队列,展开在换个队列,可以看到,现在他占用了ab …
2019年12月31日在广西钦州东站售票大厅4名海警战士整齐列队朝着售票员行了一个庄严的军礼让这个跨年夜格外温暖当天20时20分，6名海警战士来到钦州东站，准备购买145张车票，因数量大、去往不同地点且多为长途路线，对于售票员而言工作量非常大。20时50分，4号窗口售票员袁圣媛为他们出了30张车票后，就到了车站要求的关窗结账时间。根据车站规定，售票厅各个窗口 …
我们平时开发中好像很少使用到BlockingQueue（阻塞队列），比如我们想要存储一组数据的时候会使用ArrayList，想要存储键值对数据会使用HashMap，在什么场景下需要用到BlockingQueue呢？1. BlockingQueue的应用场景当我们处理完一批数据之后，需要把这批数据发给下游方法接着处理，但是下游方法的处理速率不受控制，可能时快时 …
什么是队列?队列是一种操作受限的线性表，只允许在表的前端（front）进行删除操作又称作出队，在表的后端进行插入操作，称为入队，符合先进先出（First in First out）的特性。在队尾插入元素叫做入队，对头删除元素叫做出队。比如我们常用的 LinkedList 集合，它实现了Queue 接口，我们可以理解为 LinkedList 就是一个队列。Ja …
queue模块：消息安全地在多线程间交换，实现了多生产者、多消费者队列看源码 queue 模块包含四个实用的类：一、三种队列：1、Queue()、SimpleQueue()：先进先出队列2、LifoQueue()：先进后出队列3、PriorityQueue()：优先级队列，优先级编号，按ascii码表的顺序从小到大输出数据格式：(优先级编号，数据)二、四个类 …
1 先回顾一下Java原生自带的DelayQueue自己实现java.util.concurrent.Delayed这个接口,重写getDelay(计算剩余时间)方法,重写compareTo(比较哪个任务更早过期，计算优先级)方法。调用add()方法添加延迟任务，add()方法里面会调用offer()方法,offer()方法会调用q.offer(),q是Pr …
我使用过 Redis 做异步队列，并且在不同的场景下采用过不同的方式。Redis 因其高性能、易用性和丰富的数据结构，非常适合作为异步队列的解决方案。 以下是我使用 Redis 做异步队列的一些常见方式和经验：1. 基于 List 数据结构的简单队列 (最常用)这是最简单也是最常用的方式，利用 Redis 的 List 数据结构的 LPUSHRPUSH (入 …