Lines Matching defs:cache
15 package com.google.common.cache;
17 import static com.google.common.cache.TestingCacheLoaders.identityLoader;
18 import static com.google.common.cache.TestingRemovalListeners.countingRemovalListener;
23 import com.google.common.cache.TestingCacheLoaders.IdentityLoader;
24 import com.google.common.cache.TestingRemovalListeners.CountingRemovalListener;
37 * Tests relating to cache expiration: make sure entries expire at the right times, make sure
53 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
58 checkExpiration(cache, loader, ticker, removalListener);
65 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
70 checkExpiration(cache, loader, ticker, removalListener);
73 private void checkExpiration(LoadingCache<String, Integer> cache, WatchedCreatorLoader loader,
77 assertEquals(Integer.valueOf(VALUE_PREFIX + i), cache.getUnchecked(KEY_PREFIX + i));
82 assertEquals(Integer.valueOf(VALUE_PREFIX + i), cache.getUnchecked(KEY_PREFIX + i));
86 CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
88 assertEquals("Map must be empty by now", 0, cache.size());
92 CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
102 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
107 runExpirationTest(cache, loader, ticker, removalListener);
114 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
119 runExpirationTest(cache, loader, ticker, removalListener);
122 private void runExpirationTest(LoadingCache<String, Integer> cache, WatchedCreatorLoader loader,
126 assertEquals(Integer.valueOf(VALUE_PREFIX + i), cache.getUnchecked(KEY_PREFIX + i));
131 assertEquals(Integer.valueOf(VALUE_PREFIX + i), cache.getUnchecked(KEY_PREFIX + i));
139 cache.getUnchecked(KEY_PREFIX + 11);
142 assertEquals(1, Iterators.size(cache.asMap().entrySet().iterator()));
143 assertEquals(1, Iterators.size(cache.asMap().keySet().iterator()));
144 assertEquals(1, Iterators.size(cache.asMap().values().iterator()));
146 CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
149 assertFalse(cache.asMap().containsKey(KEY_PREFIX + i));
154 assertFalse(cache.asMap().containsKey(KEY_PREFIX + i));
156 assertEquals(Integer.valueOf(VALUE_PREFIX + i), cache.getUnchecked(KEY_PREFIX + i));
161 CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
165 CacheTesting.expireEntries((LoadingCache<?, ?>) cache, EXPIRING_TIME, ticker);
195 LoadingCache<Integer, AtomicInteger> cache = CacheBuilder.newBuilder()
203 cache.getUnchecked(10).incrementAndGet();
208 int remaining = cache.getUnchecked(10).get();
216 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
221 runRemovalScheduler(cache, removalListener, loader, ticker, KEY_PREFIX, EXPIRING_TIME);
228 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
233 runRemovalScheduler(cache, removalListener, loader, ticker, KEY_PREFIX, EXPIRING_TIME);
240 LoadingCache<String, Integer> cache = CacheBuilder.newBuilder()
246 runRemovalScheduler(cache, removalListener, loader, ticker, KEY_PREFIX, EXPIRING_TIME);
253 LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder()
259 cache.getUnchecked(i);
262 Set<Integer> keySet = cache.asMap().keySet();
270 getAll(cache, asList(0, 1, 2));
271 CacheTesting.drainRecencyQueues(cache);
280 getAll(cache, asList(5, 7, 9));
281 CacheTesting.drainRecencyQueues(cache);
305 LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder()
311 cache.getUnchecked(i);
314 Set<Integer> keySet = cache.asMap().keySet();
322 getAll(cache, asList(0, 1, 2));
323 CacheTesting.drainRecencyQueues(cache);
328 cache.get(2, Callables.returning(-2));
329 CacheTesting.drainRecencyQueues(cache);
334 cache.asMap().put(3, -3);
339 cache.asMap().replace(4, -4);
352 LoadingCache<Integer, Integer> cache = CacheBuilder.newBuilder()
359 cache.getUnchecked(i);
363 cache.getUnchecked(i);
367 Set<Integer> keySet = cache.asMap().keySet();
371 getAll(cache, asList(1, 3));
372 CacheTesting.drainRecencyQueues(cache);
377 getAll(cache, asList(6, 8));
378 CacheTesting.drainRecencyQueues(cache);
383 cache.asMap().put(3, -3);
384 getAll(cache, asList(1));
385 CacheTesting.drainRecencyQueues(cache);
390 cache.asMap().replace(6, -6);
391 cache.get(8, Callables.returning(-8));
392 CacheTesting.drainRecencyQueues(cache);
397 private void runRemovalScheduler(LoadingCache<String, Integer> cache,
406 assertEquals(Integer.valueOf(i + shift1), cache.getUnchecked(keyPrefix + i));
408 assertEquals(10, CacheTesting.expirationQueueSize(cache));
414 assertEquals(10, CacheTesting.expirationQueueSize(cache));
421 cache.invalidate(keyPrefix + i);
423 Integer.valueOf(i + shift2), cache.getUnchecked(keyPrefix + i));
425 assertEquals(10, CacheTesting.expirationQueueSize(cache));
431 assertEquals(10, CacheTesting.expirationQueueSize(cache));
437 assertEquals(Integer.valueOf(i + shift2), cache.getUnchecked(keyPrefix + i));
443 private void getAll(LoadingCache<Integer, Integer> cache, List<Integer> keys) {
445 cache.getUnchecked(i);
