本文整理了Java中com.google.common.cache.Cache.invalidateAll()
方法的一些代码示例,展示了Cache.invalidateAll()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Cache.invalidateAll()
方法的具体详情如下:
包路径:com.google.common.cache.Cache
类名称:Cache
方法名:invalidateAll
[英]Discards all entries in the cache.
[中]丢弃缓存中的所有项。
代码示例来源:origin: jenkinsci/jenkins
/**
* Immediately clear the {@link #getLeftItems} cache.
* Useful for tests which need to verify that no links to a build remain.
* @since 1.519
*/
public void clearLeftItems() {
leftItems.invalidateAll();
}
代码示例来源:origin: jenkinsci/jenkins
/**
* Discards all entries in the cache.
*/
public void invalidateAll() {
existenceCache.invalidateAll();
detailsCache.invalidateAll();
}
代码示例来源:origin: apache/incubator-druid
@Override
public void invalidateAll(Iterable<K> keys)
{
cache.invalidateAll(keys);
}
代码示例来源:origin: ctripcorp/apollo
/**
* Clear config cache
*/
protected void clearConfigCache() {
synchronized (this) {
for (Cache c : allCaches) {
if (c != null) {
c.invalidateAll();
}
}
m_configVersion.incrementAndGet();
}
}
代码示例来源:origin: google/guava
/** @since 11.0 */
@Override
public void invalidateAll(Iterable<?> keys) {
delegate().invalidateAll(keys);
}
代码示例来源:origin: google/guava
@Override
public void invalidateAll() {
delegate().invalidateAll();
}
代码示例来源:origin: thinkaurelius/titan
@Override
public void clearCache() {
cache.invalidateAll();
expiredKeys.clear();
penaltyCountdown = new CountDownLatch(PENALTY_THRESHOLD);
}
代码示例来源:origin: google/guava
public void testInvalidateAll() {
forward.invalidateAll();
verify(mock).invalidateAll();
}
代码示例来源:origin: apache/incubator-druid
@Override
public void invalidateAll()
{
cache.invalidateAll();
cache.cleanUp();
}
代码示例来源:origin: google/j2objc
/** @since 11.0 */
@Override
public void invalidateAll(Iterable<?> keys) {
delegate().invalidateAll(keys);
}
代码示例来源:origin: thinkaurelius/titan
@Override
public synchronized void close() {
volatileVertices.clear();
cache.invalidateAll();
cache.cleanUp();
}
代码示例来源:origin: ben-manes/caffeine
@Override
public void invalidateAll() {
cache.invalidateAll();
}
代码示例来源:origin: google/j2objc
@Override
public void invalidateAll() {
delegate().invalidateAll();
}
代码示例来源:origin: google/guava
public void testInvalidateAllIterable() {
forward.invalidateAll(ImmutableList.of("key"));
verify(mock).invalidateAll(ImmutableList.of("key"));
}
代码示例来源:origin: Graylog2/graylog2-server
@Subscribe
public void handleEtagInvalidation(EtagCacheInvalidation event) {
if (event.etag().equals("")) {
LOG.trace("Invalidating all collector configuration etags");
cache.invalidateAll();
} else {
LOG.trace("Invalidating collector configuration etag {}", event.etag());
cache.invalidate(event.etag());
}
}
代码示例来源:origin: Graylog2/graylog2-server
public void invalidateAll() {
cache.invalidateAll();
clusterEventBus.post(EtagCacheInvalidation.etag(""));
}
代码示例来源:origin: google/guava
public void testInvalidateAll() {
final List<Object> invalidated = Lists.newArrayList();
Cache<Integer, Integer> cache =
new AbstractCache<Integer, Integer>() {
@Override
public Integer getIfPresent(Object key) {
throw new UnsupportedOperationException();
}
@Override
public void invalidate(Object key) {
invalidated.add(key);
}
};
List<Integer> toInvalidate = ImmutableList.of(1, 2, 3, 4);
cache.invalidateAll(toInvalidate);
assertEquals(toInvalidate, invalidated);
}
代码示例来源:origin: google/guava
public void testInvalidateAll() {
Cache<Integer, Integer> cache = CacheBuilder.newBuilder().build();
cache.put(654, 2675);
cache.put(2456, 56);
cache.put(2, 15);
cache.invalidateAll();
assertFalse(cache.asMap().containsKey(654));
assertFalse(cache.asMap().containsKey(2456));
assertFalse(cache.asMap().containsKey(2));
cache.put(654, 2675);
cache.put(2456, 56);
cache.put(2, 15);
cache.put(1, 3);
cache.invalidateAll(ImmutableSet.of(1, 2));
assertFalse(cache.asMap().containsKey(1));
assertFalse(cache.asMap().containsKey(2));
assertTrue(cache.asMap().containsKey(654));
assertTrue(cache.asMap().containsKey(2456));
}
代码示例来源:origin: google/guava
public void testLoader() throws ExecutionException {
final Cache<Integer, Integer> cache = CacheBuilder.newBuilder().build();
Callable<Integer> loader =
new Callable<Integer>() {
private int i = 0;
@Override
public Integer call() throws Exception {
return ++i;
}
};
cache.put(0, 10);
assertEquals(Integer.valueOf(10), cache.get(0, loader));
assertEquals(Integer.valueOf(1), cache.get(20, loader));
assertEquals(Integer.valueOf(2), cache.get(34, loader));
cache.invalidate(0);
assertEquals(Integer.valueOf(3), cache.get(0, loader));
cache.put(0, 10);
cache.invalidateAll();
assertEquals(Integer.valueOf(4), cache.get(0, loader));
}
代码示例来源:origin: google/guava
public void testExpiration_invalidateAll() {
FakeTicker ticker = new FakeTicker();
QueuingRemovalListener<Integer, Integer> listener =
TestingRemovalListeners.queuingRemovalListener();
Cache<Integer, Integer> cache =
CacheBuilder.newBuilder()
.expireAfterAccess(1, TimeUnit.MINUTES)
.removalListener(listener)
.ticker(ticker)
.build();
cache.put(1, 1);
ticker.advance(10, TimeUnit.MINUTES);
cache.invalidateAll();
assertThat(listener.poll().getCause()).isEqualTo(RemovalCause.EXPIRED);
}
内容来源于网络,如有侵权,请联系作者删除!