本文整理了Java中com.google.common.cache.LoadingCache.cleanUp()
方法的一些代码示例,展示了LoadingCache.cleanUp()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。LoadingCache.cleanUp()
方法的具体详情如下:
包路径:com.google.common.cache.LoadingCache
类名称:LoadingCache
方法名:cleanUp
LoadingCache.cleanUp介绍
暂无
代码示例
代码示例来源:origin: apache/kylin
public void close() {
tableFieldSchemaCache.cleanUp();
}
代码示例来源:origin: google/guava
public void testCleanUp() {
forward.cleanUp();
verify(mock).cleanUp();
}
代码示例来源:origin: kaaproject/kaa
statisticsPool = null;
writerCache.cleanUp();
writerCache = null;
sinkCounter.stop();
代码示例来源:origin: kaaproject/kaa
if ((System.currentTimeMillis() - cacheCleanupStartInterval) >= cacheCleanupInterval) {
LOG.info("Starting Writer cache cleanup.");
writerCache.cleanUp();
timedRollerPool.purge();
cacheCleanupStartInterval = System.currentTimeMillis();
代码示例来源:origin: ben-manes/caffeine
assertThat(cache.asMap().keySet()).isEmpty();
cache.cleanUp();
assertThat(removalListener.getCount()).isEqualTo(1);
assertThat(cache.asMap().keySet()).containsExactly(2);
cache.cleanUp();
CacheTesting.checkValidState(cache);
assertThat(removalListener.getCount()).isEqualTo(1);
assertThat(cache.asMap().keySet()).containsExactly(2, 4);
cache.cleanUp();
assertThat(removalListener.getCount()).isEqualTo(1);
assertThat(cache.asMap().keySet()).containsExactly(2, 4);
cache.cleanUp();
assertThat(removalListener.getCount()).isEqualTo(2);
代码示例来源:origin: rakam-io/rakam
public void clearCache() {
apiKeyCache.cleanUp();
}
代码示例来源:origin: rakam-io/rakam
@VisibleForTesting
public void clearCache() {
collectionCache.cleanUp();
schemaCache.cleanUp();
}
代码示例来源:origin: mulesoft/mule
@Override
public void dispose() {
for (Processor p : cache.asMap().values()) {
if (!(p instanceof Flow)) {
disposeIfNeeded(p, LOGGER);
}
}
cache.invalidateAll();
cache.cleanUp();
}
代码示例来源:origin: apache/servicecomb-java-chassis
serverStatsCache.cleanUp();
代码示例来源:origin: apache/servicecomb-java-chassis
@Override
public void run() {
try {
Map allServers = pingView;
Iterator instances = allServers.keySet().iterator();
while (instances.hasNext()) {
ServiceCombServer server = instances.next();
ServiceCombServerStats stats = allServers.get(server);
if ((System.currentTimeMillis() - stats.getLastVisitTime() > timerIntervalInMilis) && !ping
.ping(server.getInstance())) {
LOGGER.info("ping mark server {} failure.", server.getInstance().getInstanceId());
stats.markFailure();
}
}
serverStatsCache.cleanUp();
} catch (Throwable e) {
LOGGER.warn("LoadBalancerStatsTimer error.", e);
}
}
}, timerIntervalInMilis, timerIntervalInMilis);
代码示例来源:origin: com.bazaarvoice.emodb/emodb-common-dropwizard
@Override
public void run() {
_cache.cleanUp();
}
}, 1, 1, TimeUnit.MINUTES);
代码示例来源:origin: uk.q3c.krail/krail-i18n
@Override
public void clearCache() {
cache.invalidateAll();
cache.cleanUp();
}
代码示例来源:origin: secure-software-engineering/FlowDroid
@Override
public void purge() {
methodSideEffects.clear();
staticFieldUses.clear();
methodToUsedLocals.invalidateAll();
methodToUsedLocals.cleanUp();
methodToWrittenLocals.invalidateAll();
methodToWrittenLocals.cleanUp();
unitToPostdominator.invalidateAll();
unitToPostdominator.cleanUp();
}
代码示例来源:origin: cdapio/cdap
@VisibleForTesting
void invalidCache() {
ugiCache.invalidateAll();
ugiCache.cleanUp();
}
代码示例来源:origin: cdapio/cdap
@VisibleForTesting
public Collection getCacheKeys() {
perThreadMap.cleanUp();
return perThreadMap.asMap().keySet();
}
}
代码示例来源:origin: co.cask.cdap/cdap-data-fabric
@VisibleForTesting
public Collection getCacheKeys() {
perThreadMap.cleanUp();
return perThreadMap.asMap().keySet();
}
}
代码示例来源:origin: dremio/dremio-oss
@Override
public void close() throws Exception {
indexes.invalidateAll();
indexes.cleanUp();
closeException.close();
}
}
代码示例来源:origin: com.moz.fiji.rest/fiji-rest-lib
/** {@inheritDoc} */
@Override
public synchronized void stop() throws Exception {
Preconditions.checkState(mState.compareAndSet(State.STARTED, State.STOPPED),
"Can not stop in state %s.", mState.get());
LOG.info("Stopping ManagedFijiClient.");
ResourceUtils.closeOrLog(mZKInstances);
ResourceUtils.closeOrLog(mZKFramework);
mInstanceCaches.invalidateAll();
mInstanceCaches.cleanUp();
}
代码示例来源:origin: ihaolin/diablo
@Override
public Response cleanCache() {
try {
configCache.cleanUp();
return Response.ok(Boolean.TRUE);
} catch (Exception e){
Logs.error("failed to clear the cache, cause: {}",
Throwables.getStackTraceAsString(e));
return Response.notOk(messages.get("config.cache.clear.failed"));
}
}
}
代码示例来源:origin: org.xworker/xworker_core
@SuppressWarnings("unchecked")
public static void cleanCacheUp(ActionContext actionContext){
Thing self = actionContext.getObject("self");
//获取缓存配置
Thing cacheThing = (Thing) self.doAction("getCacheThing", actionContext);
//获取缓存对象
LoadingCache cache = (LoadingCache) cacheThing.doAction("getCache", actionContext);
cache.cleanUp();
}