源码剖析 | Prayer's Laputa

同样的，接下来要分析的线程池，首先用途自不必说，不管有没有用过，ThreadPoolExecutor的运行机制、传说中的7个参数(核心线程数corePoolSize、最大线程数maxPoolSize、等待时间keepAliveTime、时间单位timeUnit、阻塞队列blockingQueue、线程工厂threadFactory、拒绝策略rejectHandler)，相信大家都已经熟练掌握，此处不再赘述。

接下来简单过一下ThreadPoolExecutor的注释。
Continue reading »

源码分析之Spring Boot如何利用Spring Factories机制进行自动注入

spring, spring boot, 源码剖析 No Responses »

9月 172020

前言

本文所涉及spring/spring boot代码，请参考spring boot 2.2.6对应版本。

我们在刚学习spring boot时，有没有一个困惑：spring boot能够自动实例化很多第三方的依赖库？比如eureka、druid等。这个就涉及到spring boot的扩展机制spring factories。

简单来将，spring factories类似与Java SPI机制，利用该机制，我们能够自定义实现一些SDK或是spring boot starter，其实例化过程由我们来实现，使用方只需要在项目中引入包、不需要或是只需做很少的配置。

Spring Factories的核心

spring factories机制核心在spring-core包中定义的SpringFactoriesLoader类，该类的公有方法只有2个：
Continue reading »

源码分析之Kafka Consumer消费消息的过程

kafka, 分布式, 源码剖析 No Responses »

9月 112020

说明

本文基于Apache Kafka 2.5.1（2020.09.10拉取最新代码）

Consumer如何使用？

阅读源码前的首先要做到熟悉相关组件的概念、基本使用。而最靠谱的资料就是官方文档。

建议阅读官方文档（https://kafka.apache.org/documentation/）后，自己练习、使用kafka之后再开始阅读源码。 Continue reading »

源码分析之Netty线程模型

io, Netty, 源码剖析 No Responses »

9月 092020

不得不说的Reactor模式

提到Netty，就必须先说一下Reactor模式，源头应该是Doug Lea大神（学java的如果不知道这位神的请自己反思一下……）的Scalable IO in Java所提出的Multiple Reactors模式，参见下图

如果想知道为何出现Reactor模式，需要将IO发展过程，都说一下可能才会比较清晰，此处就不一一展开，有兴趣的童鞋可以参考这篇帖子：Reactor模式 Continue reading »

Guava RateLimiter 的使用与源码分析（令牌桶算法实现思路）

guava, 源码剖析 No Responses »

9月 022020

Guava RateLimiter基本使用

学东西时我们应该尽量去看官网、看源码、看官方给出的单元测试。

比如Guava RateLimiter，从RateLimiter类的源码注释中可以看到，官方给出的典型应用场景与使用： Continue reading »

tomcat和dubbo对于JDK线程池的修改

java, 多线程, 源码剖析 No Responses »

8月 182020

预备知识

计算任务的分类
- CPU密集型：需要线程长时间进行的复杂的运算，这种类型的任务需要少创建线程，过多的线程将会频繁引起上文切换，降低任务处理处理速度。
- IO密集型：由于线程并不是一直在运行，可能大部分时间在等待 IO 读取/写入数据，增加线程数量可以提高并发度，尽可能多处理任务。
JDK线程池，java.util.concurrent.ThreadPoolExecutor 传说中的7个参数，作用，线程池运行机制，参见下图复习