com.google.common.cache.Cache.invalidateAll()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(254)

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

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);
}

相关文章