1 一些废话
作为一名Java开发人员,池化威廉希尔官方网站 或多或少在业务代码中使用。常见的包括线程池、连接池等。也是因为Java语言超级丰富的基建,基本上这些池化能力都有着相对成熟的“工具”。
比如,需要使用线程池的时候常常会选择Spring提供的 ThreadPoolTaskExecutor , 工具内部替我们维护了线程的生命周期与任务的状态变化。
线程池的运转流程图
2 正文开始
在笔者的业务场景里,java服务需要通过命令行启动一个特殊进程,并在进程使用完后将其销毁。而业务对启动这个进程的整体耗时较为敏感,打算利用池化威廉希尔官方网站 ,将进程池化复用,去除启动进程的消耗,达到优化性能的目标。
认识 GenericObjectPool
池化威廉希尔官方网站 的概念大家可能都比较熟悉了,但真正要从零开始实现池化能力,就会感觉困难很多。好在Java丰富的基建在提供ThreadPoolTaskExecutor的同时,也提供了GenericObjectPool这个辅助我们实现自定义对象池化的工具。顺带提一句:JedisPool就是使用这个工具实现的。
GenericObjectPool构造方法一共就3个参数,只有PooledObjectFactory必传;
/** *Createsanew{@codeGenericObjectPool}thattracksanddestroys *objectsthatarecheckedout,butneverreturnedtothepool. * *@paramfactoryTheobjectfactorytobeusedtocreateobjectinstances *usedbythispool *@paramconfigThebasepoolconfigurationtouseforthispoolinstance. *Theconfigurationisusedbyvalue.Subsequentchangesto *theconfigurationobjectwillnotbereflectedinthe *pool. *@paramabandonedConfigConfigurationforabandonedobjectidentification *andremoval.Theconfigurationisusedbyvalue. */ publicGenericObjectPool(finalPooledObjectFactoryfactory, finalGenericObjectPoolConfig config,finalAbandonedConfigabandonedConfig){ }
PooledObjectFactory 按照方法注释的描述,它是专门负责给池子创建对象实例的。当然除了创建对象(makeObject), 还包括了检验、激活、销毁对象。基本涵盖了对象生命周期中的各个阶段。
voidactivateObject(PooledObjectp)throwsException; voiddestroyObject(PooledObject p)throwsException; PooledObject makeObject()throwsException; voidpassivateObject(PooledObject p)throwsException; booleanvalidateObject(PooledObject p);
更加详细的说明可以浏览 GenericObjectPool's apidocs [1]。源码的注释也很详细值得一看。
使用 GenericObjectPool
先引入依赖
org.apache.commons commons-pool2 ${version}
根据自身业务实现PooledObjectFactory接口;作者的业务场景是进程池化,那么对应的创建对象、销毁对象的方法就是创建进程和销毁进程的代码。
publicclassMyProcessFactoryimplementsPooledObjectFactory{ @Override publicvoiddestroyObject(PooledObject p)throwsException{ finalMyProcessprocess=p.getObject(); if(null!=process){ //销毁进程 process.stop(); } } @Override publicPooledObject makeObject()throwsException{ //这里就是去创建一个进程 MyProcessprocess=newMyProcess(); process.start(); returnnewDefaultPooledObject<>(process); } //剩下几个方法也可以按需实现 }
下一步就是构建 GenericObjectPool 实例
PooledObjectFactoryfactory=newMyProcessFactory(); GenericObjectPool pool=newGenericObjectPool(factory);
使用GenericObjectPool
//获取进程实例 MyProcessprocess=pool.borrowObject(); //归还实例 pool.returnObject(process);
进阶使用 GenericObjectPoolConfig
顾名思义,GenericObjectPoolConfig是池化工具的配置类;它包含了池的最大容量、池的最大空闲数、最小空闲数等核心参数。除此之外在它的父类 BaseObjectPoolConfig 中,空闲对象检测规则,对象存放队列进出规则(LIFO)等更加细节的配置。
/** *Thedefaultvalueforthe{@codemaxTotal}configurationattribute. *@seeGenericObjectPool#getMaxTotal() */ publicstaticfinalintDEFAULT_MAX_TOTAL=8; /** *Thedefaultvalueforthe{@codemaxIdle}configurationattribute. *@seeGenericObjectPool#getMaxIdle() */ publicstaticfinalintDEFAULT_MAX_IDLE=8; /** *Thedefaultvalueforthe{@codeminIdle}configurationattribute. *@seeGenericObjectPool#getMinIdle() */ publicstaticfinalintDEFAULT_MIN_IDLE=0;
通过调整这些参数值,就能创建符合业务要求的池子。下面就是能常驻4个进程的一套配置参数。
privateGenericObjectPoolConfiggenericObjectPoolConfig(){ finalGenericObjectPoolConfig config=newGenericObjectPoolConfig<>(); config.setMaxTotal(20);//池的最大容量 config.setMaxIdle(4);//最大空闲连接数 config.setMinIdle(0);//最小空闲连接数 config.setMaxWait(Duration.ofSeconds(5));//获取对象时最大等待时间 config.setTimeBetweenEvictionRuns(Duration.ofMinutes(1));//空闲对象检查间隔 config.setMinEvictableIdleTime(Duration.ofMinutes(10));//空闲对象被移除的最小空闲时间 config.setTestOnBorrow(true); config.setLifo(false); returnconfig; }
3 后续
当然真实的业务中还会有很多不相关的逻辑夹杂其中,上文基本涵盖了池化对象搭建与配置的实现方法。最终也实现了性能优化的目标。希望此文能为大家在池化运用多些帮助。
审核编辑:黄飞
-
JAVA
+关注
关注
19文章
2967浏览量
104733 -
编程语言
+关注
关注
10文章
1944浏览量
34721 -
线程池
+关注
关注
0文章
57浏览量
6846
原文标题:池化威廉希尔官方网站 在真实业务中的实践
文章出处:【微信号:芋道源码,微信公众号:芋道源码】欢迎添加关注!文章转载请注明出处。
发布评论请先 登录
相关推荐
评论