1.1 定义 Kafka 是一个分布式的基于发布/订阅模式的消息队列（Message Queue） ， 主要应用于大数据实时处理领域 1.2 消息队列 1.2.1 传统消息队列的应用场景 ? 使用消息队列的好处 1） 解耦允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。 2） ...
分类：
其他好文 时间：
2021-03-30 13:07:59
阅读次数：
0
一、为何选择线程池，不用时创建线程呢？ 池化技术：提前准备一些资源，在需要时可以重复使用这些预先准备的资源。常见的池化技术的使用有：线程池、内存池、数据库连接池、HttpClient 连接池。 线程池作为池化技术的一种实践，本质上也是同样的思想，提前备好资源以备不时之需。因此，线程池相比较任务出现再 ...
分类：
编程语言 时间：
2021-03-29 12:47:30
阅读次数：
0
Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统，专注于实时处理的异步任务队列，同时也支持任务调度。本系列将通过源码分析，和大家一起深入学习 Celery。本文是系列第二篇，继续探究 Celery 架构。 ...
分类：
其他好文 时间：
2021-03-29 12:19:38
阅读次数：
0
POJ百练 4116 拯救行动 【有序队列】 1.此题存在"慢路"（有守卫的位置）与"快路"，遇到"慢路"需要消耗多倍时间/资源。故需要给类加一个是否"可直接判断"累减属性，对于"慢路"，每次访问都减一，直到该属性转变为"可判断"，此后与正常通路点一致； 2.关于python题解版本，参考hzw大佬 ...
分类：
编程语言 时间：
2021-03-29 11:57:13
阅读次数：
0
/* 实现一个线程安全的队列 */ template <class T> class SafeQueue { public: SafeQueue(void):q(),m(),c() {} ~SafeQueue(void) {} // Add an element to the queue. void ...
分类：
编程语言 时间：
2021-03-18 14:12:09
阅读次数：
0
实现原理 AQS（AbstractQueuedSynchronizer），抽象的队列式同步器 AQS 维护了一个 state（共享资源变量）和一个 FIFO 线程等待队列（CLH 队列），多个线程竞争 state 被阻塞时就会进入此队列中。 State state 使用 volatile 修饰的一个 ...
分类：
编程语言 时间：
2021-03-17 15:06:57
阅读次数：
0
(Azure Service Bus服务总线的两大类消息处理方式： 队列Queue和主题Topic) 问题描述 使用Service Bus作为企业消息代理，当有大量的数据堆积再Queue或Topic中时，如何来优化接收端处理消息的能力呢？ 详细解释 在接收端(Receover)的代码中，有两个属性与 ...
分类：
其他好文 时间：
2021-03-17 14:56:44
阅读次数：
0
一、相关依赖 <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> < ...
分类：
其他好文 时间：
2021-03-17 14:08:25
阅读次数：
0
首先，在说这个之前，我们先把event loop再复习一遍: JS主线程不断的循环往复的从任务队列中读取任务，执行任务，其中运行机制称为事件循环（event loop).那么提到这里，在高层次上,JavaScript中有microtasks和macrotasks,它们是异步任务的一种类型.Micro ...
分类：
其他好文 时间：
2021-03-16 14:03:37
阅读次数：
0
大意： 有 N 块连续的木板，并有 K 个工人来粉刷，但不要求全部粉刷。每个工人有三个参数：L，P，S，表示其最多粉刷连续的 L 块木板，并且每粉刷一块木板可获得 P 元，但所粉刷的木板必须包括第 S 块。输出所能获得最大价值。 思路： dp[i][j] 表示第 i 个人粉刷到第 j 块木板，所获得 ...
分类：
其他好文 时间：
2021-03-16 13:54:41
阅读次数：
0
