队列
k8s限速队列不通过Get方法判断队列是否关闭
go.mod module use-k8s-queue go 1.19 require k8s.io/client-go v0.28.2 require ( github.com/go-logr/logr v1.2.4 // indirect golang.org/x/time v0.3.0 // ......
RabbitMQ安装延迟队列插件rabbitmq-delayed-message-exchange
一、下载安装包 1、根据rabbitmq版本需求，查看需要安装的erlang版本 https://www.rabbitmq.com/which-erlang.html 2、下载erlang安装包。 rpm包下载：https://github.com/rabbitmq/erlang-rpm/relea ......
Python消息队列之Huey
缘起: 之前在Python中使用最多的就是Celery, 同样的在这次项目中使用了Celery+eventlet的方式,但是由于具体执行的逻辑是使用的异步编写的, 当时就出现了一个问题,当使用httpx的AsyncClient发送一个网络请求的时候, 发生了阻塞, 导致整个程序无法完整执行. 于是就 ......
【排序链表】（自顶向下/自底向上）归并排序、优先队列
leetcode 148. 排序链表 自顶向下归并排序 用快慢指针找到序列中间位置 这里要注意一个细节：始终使fast指向链表尾节点的next节点(也就是null)，这样slow指向后半段链表的起点，避免出现死循环。 前半段链表[head, slow)，后半段[slow, fast) 合并两个排序链 ......
消息队列RabbitMQ简介
大家好，我是joker，希望你快乐。 RabbitMQ是什么 RabbitMQ是基于AMQP(Advanced Message Queue Protocol)高级消息队列协议实现的一种消息队列。 重要组件 Exchange: message 到达MQ的第一站，根据分发规则，配查询表中的 routin ......
消息队列RabbitMQ之防止消息丢失
大家好，我是joker，希望你快乐。 消息队列组成 使用消息队列会有三部分：消息生产者，消息队列，消息消费者，接下来说下各部分防止消息丢失的方法。 生产者 消息生产者发送消息失败。发布确认机制，RabbitMQ会返回一个ACK标识。 消费者 消息消费者获取消息后，消费失败。开启手动确认的方式，消息成 ......
P1339 [USACO09OCT] Heat Wave G 最短路入门题 Dijkstra/SPFA/Dijkstra+优先队列优化
目录朴素的 Dijkstra 算法SPFA 算法Dijkstra + 优先队列优化 题目链接：https://www.luogu.com.cn/problem/P1339 题目大意：无向图有单源最短路。 朴素的 Dijkstra 算法 时间复杂度 \(O(n^2)\)。 #include <bits ......
算法学习Day13单调队列和优先级队列
Day13单调队列和优先级队列 By HQWQF 2023/12/25 笔记 239.滑动窗口最大值 给定一个数组 nums，有一个大小为 k 的滑动窗口从数组的最左侧移动到数组的最右侧。你只可以看到在滑动窗口内的 k 个数字。滑动窗口每次只向右移动一位。 返回滑动窗口中的最大值。 进阶： 你能在线 ......
[刷题技巧] 栈和队列相关知识点汇总
栈主要考察单调栈，队列主要考察优先队列(堆)。 栈和队列(ArrayDeque) 数据结构 ArrayDeque类是双端队列Deque接口的实现类。 Deque的含义是"double ended queue"，即双端队列，它既可以当作栈使用，性能优于Stack，也可以当作队列使用，性能优于Linke ......
算法学习Day10栈和队列part1
Day10栈和队列part1 By HQWQF 2023/12/21 笔记 232.用栈实现队列 使用栈实现队列的下列操作： push(x) -- 将一个元素放入队列的尾部。 pop() -- 从队列首部移除元素。 peek() -- 返回队列首部的元素。 empty() -- 返回队列是否为空。 ......
代码随想录算法训练营第十天 | 栈与队列理论基础，232.用栈实现队列，225.用队列实现栈
一、栈与队列理论基础 学习： 1. 定义 栈先进后出 队列先进先出 2. 底层实现 均可以通过数组或链表进行实现 二、232.用栈实现队列 题目链接： LeetCode 232.用栈实现队列 学习前： 思路： 无 学习后： 不同方法有部分功能实现是一致的，则可以进行抽象提取，实现复用性 两个栈实现队 ......
队列
机器翻译（洛谷P1540） 题目大意 有m个可存放单词和译意的单元，初始内容为空，依次读取文章单词，若在内存单元中不存在则从外存读入，载入内存，若内存数据超过m则最先录入内存单元的出队，直到文章全部翻译完，求外存查找次数。 解题思路 限定了队列容量为m，每当队列中找不到匹配单词时从外存载入，次数+1 ......
队列
1. 队列概念及结构 队列一种先进先出的数据结构, 先入队列的数据先出队列 单链表能实现队列 ? 所以以原来的单链表无法用来实现队列, 如何修改 ? 只需再加个last引用指向尾，这样尾插入队操作复杂度就能达到O(1） 但是需要注意: 这种结构的单链表只能头插实现出队 尾插实现入队, 不能头插实现入 ......
等待队列
等待队列 什么是等待队列 等待队列是内核实现阻塞和唤醒的内核机制。等待队列以循环链表为基础结构，链表头和链表项分别为等待队列头和等待队列元素。整个等待队列由等待队列头进行管理。 等待队列头使用结构体 wait_queue _head_t来表示， 等待队列头就是一个等待队列的头部，这个结构体定义在文件 ......
P1903 [国家集训队] 数颜色 / 维护队列 题解
原题链接：P1903 题意 对于一个序列，维护两个操作： 将 \(a_{x}\) 改为 \(p\)。 求 \(l\) 到 \(r\) 中有多少个不同的数 思路 这道题本来是带修莫队的板子的，但是我是使用分块做的。 具体思路挺板的...但是这道题其实有个 \(trick\)。就是我们先预处理记录 \( ......
由于系统缺少足够的缓冲区空间或队列已满，无法对套接字执行操作。
由于系统缺少足够的缓冲区空间或队列已满，无法对套接字执行操作。 其实这个是由于操作系统的tcp连接被用完了，dkron不断打开关闭连接，有些操作完成后没有正常关闭，导致大量连接处于CLOSE_WAIT状态，直到计算机再也找不到可供使用的端口使用命令：netstat -a 查看，会发现大量的tcp已连 ......
数据结构 —— 线性表、栈、队列
一、算法复杂度 【2011】设 n 是描述问题规模的非负整数，下面的程序片段时间复杂度是（） x = 2; while (x < n/2 ) x = 2*x; A O( log2(n) ) B O( n ) C O( nlog2(n) ) D O( n^2 ) 答案：Ａ 解析： x = 2^i = ......
中断下文使用工作队列
Hello World /*中断下半部分使用工作队列*/ #include <linux/module.h> #include <linux/init.h> #include <linux/kernel.h> #include <linux/irq.h> #include <linux/interr ......
消息队列
首先使用消息队列前，我们需要知道，消息队列是用来发送、接收数据的一个容器，简单的说：我们在某宝上买东西，这中间有一个快递的过程，而大多数情况下，我本人选择将我买的东西寄到某个代收点，派送员只需要按照我的要求将东西放到代收点就可以了，之后我有时间了才自己去取。消息队列就类似于这个代收点了，它能存取数据 ......
一文讲透消息队列RocketMQ实现消费幂等
这篇文章，我们聊聊消息队列中非常重要的最佳实践之一：消费幂等。 1 基础概念 消费幂等是指：当出现 RocketMQ 消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响。 例如，在支付场景下，消费者消费扣款消息，对一笔订单执行扣款操作 ......
Hadoop Yarn 调度器多队列
1.容量调度器多队列 1.为何需要多队列 调度器默认就1个default队列，不能满足生产的要求。 1个队列在任务极限的情况下，容易资源耗尽。 特殊时期通过对任务的区分可以保证重要的任务队列资源充足 按照框架区分队列，如hive/spark/flink 每个框架的任务放入指定的队列(企业用的不是特别 ......
队列
队列 1 import queue 2 q=queue.Queue() #创建队列q 3 q.put(1) #队列加上一个1 4 print(q.qsize()) #查看当前队列长度 5 print(q.get()) #从队列里拿出一个 6 print(q.qsize()) #再次查看队列长度 队列 ......
python 双端队列
创建deque # 创建空deque my_deque = deque() # 将队列变为deque my_deque = deque([1, 2, 3]) 成员检测 # 成员检测：使用 in 和 not in 运算符来检查 deque 中是否包含某个元素， if 2 in my_deque: pr ......
【合并排序链表】分治/优先队列
合并两个排序链表 模拟维护一个合并链表，每次添加两个排序链表中较小val的节点即可 模拟代码 public ListNode mergeTwo(ListNode a, ListNode b) { if(a == null) return b; if(b == null) return a; List ......
记录rabbitMQ的广播队列的错误使用导致未能正确广播的问题
背景说明： 有3个服务S1、S2、S3 现在服务S1需要发布消息到广播交换机E，并建立了两个普通队列Q1,Q2，将其绑定到广播交换机E上 服务S2和服务S3同时监听队列Q1,Q2 本意是，服务S1通过广播交换机E把消息同时推送给服务S2和S3 后面测试时，同事发现，服务S2和服务S3都只接收到了部分 ......
清空ActiveMQ中的Scheduled延时队列
要清空ActiveMQ中的Scheduled延时队列，可以执行以下步骤： 停止ActiveMQ服务器。 在ActiveMQ数据存储目录中找到存储延时消息的目录。该目录的默认位置是<activemq_home>/data/localhost/Scheduled. 删除该目录下的所有文件，这将清空延时队 ......
并发使用(多线程 多进程 进程池 线程池 协程和异步编程) 队列
目录一、多线程、多进程、进程池、线程池、协程与异步区别多线程（Multithreading）多进程（Multiprocessing）进程池（Multiprocessing Pool）线程池（Multithreading Pool）协程（Coroutine）异步编程（Asynchronous Prog ......
阻塞队列linkedBlockQuene和syncroBlockQuene的区别？
在Java中，LinkedBlockingQueue 和 SynchronousQueue 是两种不同类型的阻塞队列，它们有一些关键的区别： 实现机制： LinkedBlockingQueue 使用一个链表实现的有界或无界队列。有界队列的容量是固定的，而无界队列的容量理论上是无限的。 Synchro ......
【一个队列实现栈】Java队列——Queue接口-LinkedList实现类
leetcode 225. 用队列实现栈 题意：用一个队列实现栈 题解： （1）弹栈：将队头开始的前size()-1个元素全部出队然后重新入队，使队尾元素循环到队头，然后弹出 （2）获取栈顶元素：先将队头开始的前size()-1个元素全部出队然后重新入队，使队尾元素循环到队头，此时队头元素即为栈顶元 ......
【双栈实现队列】Java——Stack类
leetcode 232. 用栈实现队列 题意：双栈实现队列；要求每个入队、出队操作均摊O(1)复杂度 题解： 用一个栈in维护入队元素，另一个栈out维护出队元素 出队或取队头元素：首先判断栈out是否为空，如果为空，将栈in中的元素pop()到栈out中，那么栈out栈顶元素即为原队列队头元素。 ......