Java的延迟队列（DelayQueue）是一种带有延迟时间的阻塞队列，最初在JDK1.5中引入。它允许我们向队列中添加具有延迟时间的元素，并在元素到期后从队列中获取这些元素。一、实现原理Java 延迟队列的实现基于 priority queue (优先级队列)，队列中的元素根据到期时间排序。队列头部是最先到期的元素，每个元素都可以有不同的到期时间。Dela …
优先队列
业务背景在一个项目中需要实现一个功能，商品价格发生变化时将商品价格打印在商品主图上面，那么需要在价格发生变动的时候触发合成一张带价格的图片，每一次触发合图时计算价格都是获取当前最新的价格。上游价格变化的因素很多，变化很频繁，下游合图消耗GPU资源较大，处理容量较低。上游生产速度很快，下游处理速度很慢，上下游处理速度存在巨大差距时，我们首先可以想到使用消息队列 …
前言上篇文章介绍了 Python 中的多线程。今天来介绍下编程中常会用到的一个数据结构 - 队列。不知道大家是否还记得什么是数据结构呢？在很早很早以前，Python小课堂的初期，讲了许多 Python 原生的数据结构。比如 list、tuple、dict 等。。。既然叫数据结构，实际上就是为了给计算机存储数据用的一种结构体。不同的数据结构都有其不同的特点。那 …
前言RabbitMQ是目前非常热门的一款消息中间件，不管是互联网大厂还是中小企业都在大量使用。作为一名合格的开发者，有必要对RabbitMQ有所了解。以熟悉的电商场景为例，如果商品服务和订单服务是两个不同的微服务，在下单的过程中订单服务需要调用商品服务进行扣库存操作。按照传统的方式，下单过程要等到调用完毕之后才能返回下单成功，如果网络产生波动等原因使得商品服 …
Python中的队列源代码位于 libqueue.py 「链接」中该queue模块实现了多生产者、多消费者队列。当必须在多个线程之间安全地交换信息时，queue模块特别有用。该Queue模块中的类实现了所有必需的锁定语义。该模块实现了三种类型的队列，它们仅在检索条目的顺序上有所不同。在FIFO（先进先出） 队列中，最先添加的任务是最先检索的。在 LIFO （ …
MySQL消息双雄：去重保序+死信处理实战用这招让你家系统再也不丢消息和重复MySQL十亿级消息库设计：从丢包到可靠传输手把手教你用MySQL搞定秒杀级消息队列在分布式系统中，消息传递是业务解耦、异步处理的核心枢纽。而支撑这一枢纽的message_store消息存储库与消息队列库message_queue，却常因设计不当陷入数据泥潭。存储库困境：消息重复入库 …
#记录我的2024#大家好，又见面了，我是 GitHub 精选君！背景介绍在系统访问量逐渐增大，高并发、分布式系统成为了企业技术架构升级的必由之路。在这样的背景下，异步任务队列扮演着至关重要的角色，它能有效地分摊服务器负载，提高系统的可扩展性与用户体验。然而，设计一个既简单又可靠、高效的分布式任务队列系统是一项挑战。开发者们需要考虑任务的调度、执行、失败重 …
优先队列（Priority Queue）是一种特殊的队列，其中每个元素都关联有一个优先级。优先级高的元素先被取出。通常采用堆（Heap）数据结构来实现优先队列。优先队列的主要操作包括插入元素、删除优先级最高的元素和获取优先级最高的元素等。插入操作将元素插入到队列中，并根据元素的优先级进行排序。删除操作删除优先级最高的元素，并返回该元素。获取操作返回优先级最高 …
来自：程序员小灰（微信号：chengxuyuanxiaohui）这一次，我们来讲一讲二叉堆的另外一个应用：优先队列队列的特点是什么？聪明的小伙伴们都知道，是先进先出（FIFO）。入队列：出队列：那么，优先队列又是什么样子呢？优先队列不再遵循先入先出的原则，而是分为两种情况：最大优先队列，无论入队顺序，当前最大的元素优先出队。最小优先队列，无论入队顺序，当前最 …