池化技术：让真实业务效率飙升的利器

👉 这是一个或许对你有用 的社群

🐱 一对一交流/面试小册/简历优化/求职解惑，欢迎加入 「 芋道快速开发平台 」 知识星球。 下面是星球提供的部分资料：

• 《项目实战（视频）》 ：从书中学，往事中 “练 ”
• 《互联网高频面试题》 ：面朝简历学习，春暖花开
• 《架构 x 系统设计》 ：摧枯拉朽，掌控面试高频场景题
• 《精进 Java 学习指南》 ：系统学习，互联网主流技术栈
• 《必读 Java 源码专栏》 ：知其然，知其所以然

• 1 一些废话
• 线程池的运转流程图
• 2 正文开始
• 认识 GenericObjectPool
• 使用 GenericObjectPool
• 进阶使用 GenericObjectPoolConfig
• 3 后续

1 一些废话

作为一名Java开发人员，池化技术或多或少在业务代码中使用。常见的包括线程池、连接池等。也是因为Java语言超级丰富的基建，基本上这些池化能力都有着相对成熟的“工具”。

比如，需要使用线程池的时候常常会选择Spring提供的 ThreadPoolTaskExecutor , 工具内部替我们维护了线程的生命周期与任务的状态变化。

线程池的运转流程图

基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

• 项目地址：https://github.com/YunaiV/ruoyi-vue-pro
• 视频教程：https://doc.iocoder.cn/video/

2 正文开始

在笔者的业务场景里，java服务需要通过命令行启动一个特殊进程，并在进程使用完后将其销毁。而业务对启动这个进程的整体耗时较为敏感，打算利用池化技术，将进程池化复用，去除启动进程的消耗，达到优化性能的目标。

认识 GenericObjectPool

池化技术的概念大家可能都比较熟悉了，但真正要从零开始实现池化能力，就会感觉困难很多。好在Java丰富的基建在提供 ThreadPoolTaskExecutor 的同时，也提供了 GenericObjectPool 这个辅助我们实现自定义对象池化的工具。顺带提一句：JedisPool就是使用这个工具实现的。

GenericObjectPool 构造方法一共就3个参数，只有 PooledObjectFactory 必传;

/**
 * Creates a new {@code GenericObjectPool} that tracks and destroys
 * objects that are checked out, but never returned to the pool.
 *
 * @param factory   The object factory to be used to create object instances
 *                  used by this pool
 * @param config    The base pool configuration to use for this pool instance.
 *                  The configuration is used by value. Subsequent changes to
 *                  the configuration object will not be reflected in the
 *                  pool.
 * @param abandonedConfig  Configuration for abandoned object identification
 *                         and removal.  The configuration is used by value.
 */
public GenericObjectPool(final PooledObjectFactory factory,
        final GenericObjectPoolConfig config, final AbandonedConfig abandonedConfig) {
}

PooledObjectFactory 按照方法注释的描述，它是专门负责给池子创建对象实例的。当然除了创建对象(makeObject), 还包括了检验、激活、销毁对象。基本涵盖了对象生命周期中的各个阶段。

void activateObject(PooledObject p) throws Exception;

void destroyObject(PooledObject p) throws Exception;

PooledObject makeObject() throws Exception;

void passivateObject(PooledObject p) throws Exception;

boolean validateObject(PooledObject p);

更加详细的说明可以浏览 GenericObjectPool's apidocs [1]。源码的注释也很详细值得一看。

使用 GenericObjectPool

先引入依赖

   org.apache.commons
   commons-pool2
   ${version}

根据自身业务实现 PooledObjectFactory 接口；作者的业务场景是进程池化，那么对应的创建对象、销毁对象的方法就是创建进程和销毁进程的代码。

public class MyProcessFactory implements PooledObjectFactory<MyProcess> {
    @Override
    public void destroyObject(PooledObject p) throws Exception {
        final MyProcess process = p.getObject();
        if (null != process) {
            // 销毁进程
            process.stop();
        }
    }

    @Override
    public PooledObject makeObject() throws Exception {
        // 这里就是去创建一个进程
        MyProcess process = new MyProcess();
        process.start();
        return new DefaultPooledObject<>(process);
    }
    
    // 剩下几个方法也可以按需实现
}

下一步就是构建 GenericObjectPool 实例

PooledObjectFactory factory = new MyProcessFactory();
GenericObjectPool pool = new GenericObjectPool(factory);

使用GenericObjectPool

// 获取进程实例
MyProcess process = pool.borrowObject();

// 归还实例
pool.returnObject(process);

进阶使用 GenericObjectPoolConfig

顾名思义， GenericObjectPoolConfig 是池化工具的配置类；它包含了池的最大容量、池的最大空闲数、最小空闲数等核心参数。除此之外在它的父类 BaseObjectPoolConfig 中，空闲对象检测规则，对象存放队列进出规则(LIFO)等更加细节的配置。

/**
 * The default value for the {@code maxTotal} configuration attribute.
 * @see GenericObjectPool#getMaxTotal()
 */
public static final int DEFAULT_MAX_TOTAL = 8;

/**
 * The default value for the {@code maxIdle} configuration attribute.
 * @see GenericObjectPool#getMaxIdle()
 */
public static final int DEFAULT_MAX_IDLE = 8;

/**
 * The default value for the {@code minIdle} configuration attribute.
 * @see GenericObjectPool#getMinIdle()