Skip to content

Population

Ben Manes edited this page Mar 22, 2015 · 25 revisions

Caffeine provides three types of population strategies: manual, loading synchronously, and loading asynchronously.

Manual

Cache<Key, Graph> graphs = Caffeine.newBuilder()
    .expireAfterWrite(10, TimeUnit.MINUTES)
    .maximumSize(10_000)
    .removalListener(MY_LISTENER)
    .build();
// Lookup an entry
cache.getIfPresent(key);
// Lookup and compute an entry if absent
cache.get(key, k -> createExpensiveGraph(key));
// Insert or update an entry
cache.put(key, value);
// Remove an entry
cache.invalidate(key);

The Cache interface allows for explicit control of looking up, updating, and invalidating entries.

Entries may be inserted into the cache directly with cache.put(key, value). This overwrites any previous entry in the cache for the specified key. Changes can also be made to a cache using any of the ConcurrentMap methods exposed by the Cache.asMap() view.

Loading

LoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    .maximumSize(10_000)
    .expireAfterWrite(10, TimeUnit.MINUTES)
    .removalListener(MY_LISTENER)
    .build(key -> createExpensiveGraph(key));
// Lookup and compute an entry if absent
cache.get(key);
// Lookup and compute entries that are absent
cache.getAll(keys);

A LoadingCache is a Cache built with an attached CacheLoader.

Bulk lookups can be performed with the method getAll. By default, getAll will issue a separate call to CacheLoader.load for each key which is absent from the cache. When bulk retrieval is more efficient than many individual lookups, you can override CacheLoader.loadAll to exploit this.

Note that you can write a CacheLoader.loadAll implementation that loads values for keys that were not specifically requested. For example, if computing the value of any key from some group gives you the value for all keys in the group, loadAll might load the rest of the group at the same time.

Asynchronously Loading

AsyncLoadingCache<Key, Graph> graphs = Caffeine.newBuilder()
    .maximumSize(10_000)
    .expireAfterWrite(10, TimeUnit.MINUTES)
    .removalListener(MY_LISTENER)
    .buildAsync(key -> createExpensiveGraph(key));
// Lookup and compute an entry if absent
cache.get(key);
// Lookup and compute entries that are absent
cache.getAll(keys);

A AsyncLoadingCache is a LoadingCache variant that computes entries on an Executor and returns a CompletableFuture. This allows utilizing caches with the popular reactive programming model.

The synchronous() view provides a LoadingCache that blocks until the asynchronous computation completes.

Clone this wiki locally