热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

org.apache.commons.pool2.impl.AbandonedConfig.setRemoveAbandonedOnBorrow()方法的使用及代码示例

本文整理了Java中org.apache.commons.pool2.impl.AbandonedConfig.setRemoveAbandonedOnBorrow()

本文整理了Java中org.apache.commons.pool2.impl.AbandonedConfig.setRemoveAbandonedOnBorrow()方法的一些代码示例,展示了AbandonedConfig.setRemoveAbandonedOnBorrow()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。AbandonedConfig.setRemoveAbandonedOnBorrow()方法的具体详情如下:
包路径:org.apache.commons.pool2.impl.AbandonedConfig
类名称:AbandonedConfig
方法名:setRemoveAbandonedOnBorrow

AbandonedConfig.setRemoveAbandonedOnBorrow介绍

[英]Flag to remove abandoned objects if they exceed the removeAbandonedTimeout when borrowObject is invoked.
[中]当调用borrowObject时,如果废弃对象超过RemoveBandonedTimeout,则将其删除的标志。

代码示例

代码示例来源:origin: qiujiayu/AutoLoadCache

private DataLoaderFactory() {
GenericObjectPoolConfig cOnfig= new GenericObjectPoolConfig();
config.setMaxTotal(1024);
config.setMaxIdle(50);
config.setMinIdle(8);
config.setBlockWhenExhausted(false);// 当Pool中没有对象时不等待,而是直接new个新的
AbandonedConfig abandOnConfig= new AbandonedConfig();
abandonConfig.setRemoveAbandonedTimeout(300);
abandonConfig.setRemoveAbandonedOnBorrow(true);
abandonConfig.setRemoveAbandonedOnMaintenance(true);
factory = new GenericObjectPool(this, config, abandonConfig);
}

代码示例来源:origin: org.apache.commons/commons-pool2

@Test
public void testGetLastBorrowTrace() throws Exception {
final AbandonedConfig abandOnedConfig= new AbandonedConfig();
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedTimeout(1);
abandonedConfig.setLogAbandoned(true);
try (final GenericObjectPool pool = new GenericObjectPool<>(new SimpleFactory(),
new GenericObjectPoolConfig(), abandonedConfig)) {
pool.borrowObject();
// pool.returnObject(s1); // Object not returned, causes abandoned object created exception
final Set strings = pool.listAllObjects();
final DefaultPooledObjectInfo s1Info = strings.iterator().next();
final String lastBorrowTrace = s1Info.getLastBorrowTrace();
Assert.assertTrue(lastBorrowTrace.startsWith("Pooled object created"));
}
}
}

代码示例来源:origin: org.apache.commons/commons-pool2

@Before
public void setUp() {
log = new StringWriter();
final PrintWriter pw = new PrintWriter(log);
final AbandonedConfig abandOnedConfig= new AbandonedConfig();
abandonedConfig.setLogAbandoned(true);
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setUseUsageTracking(true);
abandonedConfig.setRemoveAbandonedTimeout(ABANDONED_TIMEOUT_SECS);
abandonedConfig.setLogWriter(pw);
final GenericObjectPoolConfig cOnfig= new GenericObjectPoolConfig();
config.setMaxTotal(3);
final PooledObjectFactory factory = new TestObjectFactory();
final ObjectPool innerPool =
new GenericObjectPool<>(factory, config, abandonedConfig);
pool = new ProxiedObjectPool<>(innerPool, getproxySource());
}

代码示例来源:origin: org.apache.commons/commons-pool2

@Before
public void setUp() throws Exception {
abandOnedConfig= new AbandonedConfig();
// -- Uncomment the following line to enable logging --
// abandonedConfig.setLogAbandoned(true);
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedTimeout(1);
pool = new GenericObjectPool<>(
new SimpleFactory(),
new GenericObjectPoolConfig(),
abandonedConfig);
}

代码示例来源:origin: org.apache.commons/commons-pool2

/**
* Sets the abandoned object removal configuration.
*
* @param abandonedConfig the new configuration to use. This is used by value.
*
* @see AbandonedConfig
*/
public void setAbandonedConfig(final AbandonedConfig abandonedConfig) {
if (abandOnedConfig== null) {
this.abandOnedConfig= null;
} else {
this.abandOnedConfig= new AbandonedConfig();
this.abandonedConfig.setLogAbandoned(abandonedConfig.getLogAbandoned());
this.abandonedConfig.setLogWriter(abandonedConfig.getLogWriter());
this.abandonedConfig.setRemoveAbandonedOnBorrow(abandonedConfig.getRemoveAbandonedOnBorrow());
this.abandonedConfig.setRemoveAbandonedOnMaintenance(abandonedConfig.getRemoveAbandonedOnMaintenance());
this.abandonedConfig.setRemoveAbandonedTimeout(abandonedConfig.getRemoveAbandonedTimeout());
this.abandonedConfig.setUseUsageTracking(abandonedConfig.getUseUsageTracking());
this.abandonedConfig.setRequireFullStackTrace(abandonedConfig.getRequireFullStackTrace());
}
}

代码示例来源:origin: org.apache.commons/commons-dbcp2

/**
* @param removeAbandonedOnBorrow
* true means abandoned connections may be removed when connections are borrowed from the pool.
* @see #getRemoveAbandonedOnBorrow()
*/
public void setRemoveAbandonedOnBorrow(final boolean removeAbandonedOnBorrow) {
if (abandOnedConfig== null) {
abandOnedConfig= new AbandonedConfig();
}
abandonedConfig.setRemoveAbandonedOnBorrow(removeAbandonedOnBorrow);
final GenericObjectPool gop = this.connectionPool;
if (gop != null) {
gop.setAbandonedConfig(abandonedConfig);
}
}

代码示例来源:origin: org.apache.commons/commons-pool2

public void testAbandonedReturn() throws Exception {
abandOnedConfig= new AbandonedConfig();
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedTimeout(1);

代码示例来源:origin: indeedeng/proctor

private static ObjectPool createObjectPool(final PooledObjectFactory factory) {
final GenericObjectPoolConfig objectPoolCOnfig= new GenericObjectPoolConfig();
objectPoolConfig.setMinEvictableIdleTimeMillis(TimeUnit.HOURS.toMillis(1)); // arbitrary, but positive so objects do get evicted
objectPoolConfig.setTimeBetweenEvictionRunsMillis(TimeUnit.MINUTES.toMillis(10)); // arbitrary, but positive so objects do get evicted
objectPoolConfig.setJmxEnabled(false);
objectPoolConfig.setBlockWhenExhausted(false);
objectPoolConfig.setMaxTotal(-1); // uncapped number of objects in the pool
final AbandonedConfig abandOnedConfig= new AbandonedConfig();
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedTimeout((int) TimeUnit.MINUTES.toSeconds(30));
return new GenericObjectPool(factory, objectPoolConfig, abandonedConfig);
}

代码示例来源:origin: com.indeed/proctor-store-svn

private static ObjectPool createObjectPool(final PooledObjectFactory factory) {
final GenericObjectPoolConfig objectPoolCOnfig= new GenericObjectPoolConfig();
objectPoolConfig.setMinEvictableIdleTimeMillis(TimeUnit.HOURS.toMillis(1)); // arbitrary, but positive so objects do get evicted
objectPoolConfig.setTimeBetweenEvictionRunsMillis(TimeUnit.MINUTES.toMillis(10)); // arbitrary, but positive so objects do get evicted
objectPoolConfig.setJmxEnabled(false);
objectPoolConfig.setBlockWhenExhausted(false);
objectPoolConfig.setMaxTotal(-1); // uncapped number of objects in the pool
final AbandonedConfig abandOnedConfig= new AbandonedConfig();
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedTimeout((int) TimeUnit.MINUTES.toSeconds(30));
return new GenericObjectPool(factory, objectPoolConfig, abandonedConfig);
}

代码示例来源:origin: io.leopard/leopard-redis

public JedisPool(final JedisPoolConfig poolConfig, final String host, final int port, final int timeout, String password) {
super(poolConfig, host, port, timeout, formatPassword(password));
this.initRedisConnectionListener(poolConfig, host, port, timeout);
AbandonedConfig abandOnedConfig= new AbandonedConfig();
abandonedConfig.setRemoveAbandonedTimeout(10);
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedOnMaintenance(true);
internalPool.setAbandonedConfig(abandonedConfig);
}

代码示例来源:origin: rancher/cattle

@PostConstruct
public void init() {
if (getContextPool() == null) {
GenericObjectPoolConfig cOnfig= new GenericObjectPoolConfig();
PoolConfig.setConfig(config, "ldap.context.pool", "ldap.context.pool.", "global.pool.");
config.setTestOnBorrow(true);
LdapServiceContextPoolFactory serviceCOntextPoolFactory= new LdapServiceContextPoolFactory(getConstantsConfig());
setContextPool(new GenericObjectPool<>(serviceContextPoolFactory, config));
AbandonedConfig abandOnedConfig= new AbandonedConfig();
abandonedConfig.setUseUsageTracking(true);
abandonedConfig.setRemoveAbandonedOnMaintenance(true);
abandonedConfig.setRemoveAbandonedOnBorrow(true);
abandonedConfig.setRemoveAbandonedTimeout(60);
getContextPool().setAbandonedConfig(abandonedConfig);
}
}

代码示例来源:origin: org.apache.directory.api/api-ldap-client-all

/**
* Sets the abandoned object removal configuration.
*
* @param abandonedConfig the new configuration to use. This is used by value.
*
* @see AbandonedConfig
*/
public void setAbandonedConfig(final AbandonedConfig abandonedConfig) {
if (abandOnedConfig== null) {
this.abandOnedConfig= null;
} else {
this.abandOnedConfig= new AbandonedConfig();
this.abandonedConfig.setLogAbandoned(abandonedConfig.getLogAbandoned());
this.abandonedConfig.setLogWriter(abandonedConfig.getLogWriter());
this.abandonedConfig.setRemoveAbandonedOnBorrow(abandonedConfig.getRemoveAbandonedOnBorrow());
this.abandonedConfig.setRemoveAbandonedOnMaintenance(abandonedConfig.getRemoveAbandonedOnMaintenance());
this.abandonedConfig.setRemoveAbandonedTimeout(abandonedConfig.getRemoveAbandonedTimeout());
this.abandonedConfig.setUseUsageTracking(abandonedConfig.getUseUsageTracking());
this.abandonedConfig.setRequireFullStackTrace(abandonedConfig.getRequireFullStackTrace());
}
}

推荐阅读
author-avatar
白杨树问天
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有