001/* 002 * Copyright (C) 2009 The Guava Authors 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except 005 * in compliance with the License. You may obtain a copy of the License at 006 * 007 * http://www.apache.org/licenses/LICENSE-2.0 008 * 009 * Unless required by applicable law or agreed to in writing, software distributed under the License 010 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express 011 * or implied. See the License for the specific language governing permissions and limitations under 012 * the License. 013 */ 014 015package com.google.common.cache; 016 017import static com.google.common.base.Preconditions.checkArgument; 018import static com.google.common.base.Preconditions.checkNotNull; 019import static com.google.common.base.Preconditions.checkState; 020 021import com.google.common.annotations.GwtCompatible; 022import com.google.common.annotations.GwtIncompatible; 023import com.google.common.base.Ascii; 024import com.google.common.base.Equivalence; 025import com.google.common.base.MoreObjects; 026import com.google.common.base.Supplier; 027import com.google.common.base.Suppliers; 028import com.google.common.base.Ticker; 029import com.google.common.cache.AbstractCache.SimpleStatsCounter; 030import com.google.common.cache.AbstractCache.StatsCounter; 031import com.google.common.cache.LocalCache.Strength; 032import com.google.errorprone.annotations.CheckReturnValue; 033import java.lang.ref.SoftReference; 034import java.lang.ref.WeakReference; 035import java.util.ConcurrentModificationException; 036import java.util.IdentityHashMap; 037import java.util.Map; 038import java.util.concurrent.ConcurrentHashMap; 039import java.util.concurrent.TimeUnit; 040import java.util.logging.Level; 041import java.util.logging.Logger; 042import org.checkerframework.checker.nullness.compatqual.MonotonicNonNullDecl; 043 044/** 045 * A builder of {@link LoadingCache} and {@link Cache} instances having any combination of the 046 * following features: 047 * 048 * <ul> 049 * <li>automatic loading of entries into the cache 050 * <li>least-recently-used eviction when a maximum size is exceeded 051 * <li>time-based expiration of entries, measured since last access or last write 052 * <li>keys automatically wrapped in {@linkplain WeakReference weak} references 053 * <li>values automatically wrapped in {@linkplain WeakReference weak} or {@linkplain 054 * SoftReference soft} references 055 * <li>notification of evicted (or otherwise removed) entries 056 * <li>accumulation of cache access statistics 057 * </ul> 058 * 059 * 060 * <p>These features are all optional; caches can be created using all or none of them. By default 061 * cache instances created by {@code CacheBuilder} will not perform any type of eviction. 062 * 063 * <p>Usage example: 064 * 065 * <pre>{@code 066 * LoadingCache<Key, Graph> graphs = CacheBuilder.newBuilder() 067 * .maximumSize(10000) 068 * .expireAfterWrite(10, TimeUnit.MINUTES) 069 * .removalListener(MY_LISTENER) 070 * .build( 071 * new CacheLoader<Key, Graph>() { 072 * public Graph load(Key key) throws AnyException { 073 * return createExpensiveGraph(key); 074 * } 075 * }); 076 * }</pre> 077 * 078 * <p>Or equivalently, 079 * 080 * <pre>{@code 081 * // In real life this would come from a command-line flag or config file 082 * String spec = "maximumSize=10000,expireAfterWrite=10m"; 083 * 084 * LoadingCache<Key, Graph> graphs = CacheBuilder.from(spec) 085 * .removalListener(MY_LISTENER) 086 * .build( 087 * new CacheLoader<Key, Graph>() { 088 * public Graph load(Key key) throws AnyException { 089 * return createExpensiveGraph(key); 090 * } 091 * }); 092 * }</pre> 093 * 094 * <p>The returned cache is implemented as a hash table with similar performance characteristics to 095 * {@link ConcurrentHashMap}. It implements all optional operations of the {@link LoadingCache} and 096 * {@link Cache} interfaces. The {@code asMap} view (and its collection views) have <i>weakly 097 * consistent iterators</i>. This means that they are safe for concurrent use, but if other threads 098 * modify the cache after the iterator is created, it is undefined which of these changes, if any, 099 * are reflected in that iterator. These iterators never throw {@link 100 * ConcurrentModificationException}. 101 * 102 * <p><b>Note:</b> by default, the returned cache uses equality comparisons (the {@link 103 * Object#equals equals} method) to determine equality for keys or values. However, if {@link 104 * #weakKeys} was specified, the cache uses identity ({@code ==}) comparisons instead for keys. 105 * Likewise, if {@link #weakValues} or {@link #softValues} was specified, the cache uses identity 106 * comparisons for values. 107 * 108 * <p>Entries are automatically evicted from the cache when any of {@linkplain #maximumSize(long) 109 * maximumSize}, {@linkplain #maximumWeight(long) maximumWeight}, {@linkplain #expireAfterWrite 110 * expireAfterWrite}, {@linkplain #expireAfterAccess expireAfterAccess}, {@linkplain #weakKeys 111 * weakKeys}, {@linkplain #weakValues weakValues}, or {@linkplain #softValues softValues} are 112 * requested. 113 * 114 * <p>If {@linkplain #maximumSize(long) maximumSize} or {@linkplain #maximumWeight(long) 115 * maximumWeight} is requested entries may be evicted on each cache modification. 116 * 117 * <p>If {@linkplain #expireAfterWrite expireAfterWrite} or {@linkplain #expireAfterAccess 118 * expireAfterAccess} is requested entries may be evicted on each cache modification, on occasional 119 * cache accesses, or on calls to {@link Cache#cleanUp}. Expired entries may be counted by {@link 120 * Cache#size}, but will never be visible to read or write operations. 121 * 122 * <p>If {@linkplain #weakKeys weakKeys}, {@linkplain #weakValues weakValues}, or {@linkplain 123 * #softValues softValues} are requested, it is possible for a key or value present in the cache to 124 * be reclaimed by the garbage collector. Entries with reclaimed keys or values may be removed from 125 * the cache on each cache modification, on occasional cache accesses, or on calls to {@link 126 * Cache#cleanUp}; such entries may be counted in {@link Cache#size}, but will never be visible to 127 * read or write operations. 128 * 129 * <p>Certain cache configurations will result in the accrual of periodic maintenance tasks which 130 * will be performed during write operations, or during occasional read operations in the absence of 131 * writes. The {@link Cache#cleanUp} method of the returned cache will also perform maintenance, but 132 * calling it should not be necessary with a high throughput cache. Only caches built with 133 * {@linkplain #removalListener removalListener}, {@linkplain #expireAfterWrite expireAfterWrite}, 134 * {@linkplain #expireAfterAccess expireAfterAccess}, {@linkplain #weakKeys weakKeys}, {@linkplain 135 * #weakValues weakValues}, or {@linkplain #softValues softValues} perform periodic maintenance. 136 * 137 * <p>The caches produced by {@code CacheBuilder} are serializable, and the deserialized caches 138 * retain all the configuration properties of the original cache. Note that the serialized form does 139 * <i>not</i> include cache contents, but only configuration. 140 * 141 * <p>See the Guava User Guide article on <a 142 * href="https://github.com/google/guava/wiki/CachesExplained">caching</a> for a higher-level 143 * explanation. 144 * 145 * @param <K> the most general key type this builder will be able to create caches for. This is 146 * normally {@code Object} unless it is constrained by using a method like {@code 147 * #removalListener} 148 * @param <V> the most general value type this builder will be able to create caches for. This is 149 * normally {@code Object} unless it is constrained by using a method like {@code 150 * #removalListener} 151 * @author Charles Fry 152 * @author Kevin Bourrillion 153 * @since 10.0 154 */ 155@GwtCompatible(emulated = true) 156public final class CacheBuilder<K, V> { 157 private static final int DEFAULT_INITIAL_CAPACITY = 16; 158 private static final int DEFAULT_CONCURRENCY_LEVEL = 4; 159 160 @SuppressWarnings("GoodTime") // should be a java.time.Duration 161 private static final int DEFAULT_EXPIRATION_NANOS = 0; 162 163 @SuppressWarnings("GoodTime") // should be a java.time.Duration 164 private static final int DEFAULT_REFRESH_NANOS = 0; 165 166 static final Supplier<? extends StatsCounter> NULL_STATS_COUNTER = 167 Suppliers.ofInstance( 168 new StatsCounter() { 169 @Override 170 public void recordHits(int count) {} 171 172 @Override 173 public void recordMisses(int count) {} 174 175 @SuppressWarnings("GoodTime") // b/122668874 176 @Override 177 public void recordLoadSuccess(long loadTime) {} 178 179 @SuppressWarnings("GoodTime") // b/122668874 180 @Override 181 public void recordLoadException(long loadTime) {} 182 183 @Override 184 public void recordEviction() {} 185 186 @Override 187 public CacheStats snapshot() { 188 return EMPTY_STATS; 189 } 190 }); 191 static final CacheStats EMPTY_STATS = new CacheStats(0, 0, 0, 0, 0, 0); 192 193 static final Supplier<StatsCounter> CACHE_STATS_COUNTER = 194 new Supplier<StatsCounter>() { 195 @Override 196 public StatsCounter get() { 197 return new SimpleStatsCounter(); 198 } 199 }; 200 201 enum NullListener implements RemovalListener<Object, Object> { 202 INSTANCE; 203 204 @Override 205 public void onRemoval(RemovalNotification<Object, Object> notification) {} 206 } 207 208 enum OneWeigher implements Weigher<Object, Object> { 209 INSTANCE; 210 211 @Override 212 public int weigh(Object key, Object value) { 213 return 1; 214 } 215 } 216 217 static final Ticker NULL_TICKER = 218 new Ticker() { 219 @Override 220 public long read() { 221 return 0; 222 } 223 }; 224 225 private static final Logger logger = Logger.getLogger(CacheBuilder.class.getName()); 226 227 static final int UNSET_INT = -1; 228 229 boolean strictParsing = true; 230 231 int initialCapacity = UNSET_INT; 232 int concurrencyLevel = UNSET_INT; 233 long maximumSize = UNSET_INT; 234 long maximumWeight = UNSET_INT; 235 @MonotonicNonNullDecl Weigher<? super K, ? super V> weigher; 236 237 @MonotonicNonNullDecl Strength keyStrength; 238 @MonotonicNonNullDecl Strength valueStrength; 239 240 @SuppressWarnings("GoodTime") // should be a java.time.Duration 241 long expireAfterWriteNanos = UNSET_INT; 242 243 @SuppressWarnings("GoodTime") // should be a java.time.Duration 244 long expireAfterAccessNanos = UNSET_INT; 245 246 @SuppressWarnings("GoodTime") // should be a java.time.Duration 247 long refreshNanos = UNSET_INT; 248 249 @MonotonicNonNullDecl Equivalence<Object> keyEquivalence; 250 @MonotonicNonNullDecl Equivalence<Object> valueEquivalence; 251 252 @MonotonicNonNullDecl RemovalListener<? super K, ? super V> removalListener; 253 @MonotonicNonNullDecl Ticker ticker; 254 255 Supplier<? extends StatsCounter> statsCounterSupplier = NULL_STATS_COUNTER; 256 257 private CacheBuilder() {} 258 259 /** 260 * Constructs a new {@code CacheBuilder} instance with default settings, including strong keys, 261 * strong values, and no automatic eviction of any kind. 262 * 263 * <p>Note that while this return type is {@code CacheBuilder<Object, Object>}, type parameters on 264 * the {@link #build} methods allow you to create a cache of any key and value type desired. 265 */ 266 public static CacheBuilder<Object, Object> newBuilder() { 267 return new CacheBuilder<>(); 268 } 269 270 /** 271 * Constructs a new {@code CacheBuilder} instance with the settings specified in {@code spec}. 272 * 273 * @since 12.0 274 */ 275 @GwtIncompatible // To be supported 276 public static CacheBuilder<Object, Object> from(CacheBuilderSpec spec) { 277 return spec.toCacheBuilder().lenientParsing(); 278 } 279 280 /** 281 * Constructs a new {@code CacheBuilder} instance with the settings specified in {@code spec}. 282 * This is especially useful for command-line configuration of a {@code CacheBuilder}. 283 * 284 * @param spec a String in the format specified by {@link CacheBuilderSpec} 285 * @since 12.0 286 */ 287 @GwtIncompatible // To be supported 288 public static CacheBuilder<Object, Object> from(String spec) { 289 return from(CacheBuilderSpec.parse(spec)); 290 } 291 292 /** 293 * Enables lenient parsing. Useful for tests and spec parsing. 294 * 295 * @return this {@code CacheBuilder} instance (for chaining) 296 */ 297 @GwtIncompatible // To be supported 298 CacheBuilder<K, V> lenientParsing() { 299 strictParsing = false; 300 return this; 301 } 302 303 /** 304 * Sets a custom {@code Equivalence} strategy for comparing keys. 305 * 306 * <p>By default, the cache uses {@link Equivalence#identity} to determine key equality when 307 * {@link #weakKeys} is specified, and {@link Equivalence#equals()} otherwise. 308 * 309 * @return this {@code CacheBuilder} instance (for chaining) 310 */ 311 @GwtIncompatible // To be supported 312 CacheBuilder<K, V> keyEquivalence(Equivalence<Object> equivalence) { 313 checkState(keyEquivalence == null, "key equivalence was already set to %s", keyEquivalence); 314 keyEquivalence = checkNotNull(equivalence); 315 return this; 316 } 317 318 Equivalence<Object> getKeyEquivalence() { 319 return MoreObjects.firstNonNull(keyEquivalence, getKeyStrength().defaultEquivalence()); 320 } 321 322 /** 323 * Sets a custom {@code Equivalence} strategy for comparing values. 324 * 325 * <p>By default, the cache uses {@link Equivalence#identity} to determine value equality when 326 * {@link #weakValues} or {@link #softValues} is specified, and {@link Equivalence#equals()} 327 * otherwise. 328 * 329 * @return this {@code CacheBuilder} instance (for chaining) 330 */ 331 @GwtIncompatible // To be supported 332 CacheBuilder<K, V> valueEquivalence(Equivalence<Object> equivalence) { 333 checkState( 334 valueEquivalence == null, "value equivalence was already set to %s", valueEquivalence); 335 this.valueEquivalence = checkNotNull(equivalence); 336 return this; 337 } 338 339 Equivalence<Object> getValueEquivalence() { 340 return MoreObjects.firstNonNull(valueEquivalence, getValueStrength().defaultEquivalence()); 341 } 342 343 /** 344 * Sets the minimum total size for the internal hash tables. For example, if the initial capacity 345 * is {@code 60}, and the concurrency level is {@code 8}, then eight segments are created, each 346 * having a hash table of size eight. Providing a large enough estimate at construction time 347 * avoids the need for expensive resizing operations later, but setting this value unnecessarily 348 * high wastes memory. 349 * 350 * @return this {@code CacheBuilder} instance (for chaining) 351 * @throws IllegalArgumentException if {@code initialCapacity} is negative 352 * @throws IllegalStateException if an initial capacity was already set 353 */ 354 public CacheBuilder<K, V> initialCapacity(int initialCapacity) { 355 checkState( 356 this.initialCapacity == UNSET_INT, 357 "initial capacity was already set to %s", 358 this.initialCapacity); 359 checkArgument(initialCapacity >= 0); 360 this.initialCapacity = initialCapacity; 361 return this; 362 } 363 364 int getInitialCapacity() { 365 return (initialCapacity == UNSET_INT) ? DEFAULT_INITIAL_CAPACITY : initialCapacity; 366 } 367 368 /** 369 * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The 370 * table is internally partitioned to try to permit the indicated number of concurrent updates 371 * without contention. Because assignment of entries to these partitions is not necessarily 372 * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to 373 * accommodate as many threads as will ever concurrently modify the table. Using a significantly 374 * higher value than you need can waste space and time, and a significantly lower value can lead 375 * to thread contention. But overestimates and underestimates within an order of magnitude do not 376 * usually have much noticeable impact. A value of one permits only one thread to modify the cache 377 * at a time, but since read operations and cache loading computations can proceed concurrently, 378 * this still yields higher concurrency than full synchronization. 379 * 380 * <p>Defaults to 4. <b>Note:</b>The default may change in the future. If you care about this 381 * value, you should always choose it explicitly. 382 * 383 * <p>The current implementation uses the concurrency level to create a fixed number of hashtable 384 * segments, each governed by its own write lock. The segment lock is taken once for each explicit 385 * write, and twice for each cache loading computation (once prior to loading the new value, and 386 * once after loading completes). Much internal cache management is performed at the segment 387 * granularity. For example, access queues and write queues are kept per segment when they are 388 * required by the selected eviction algorithm. As such, when writing unit tests it is not 389 * uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction 390 * behavior. 391 * 392 * <p>Note that future implementations may abandon segment locking in favor of more advanced 393 * concurrency controls. 394 * 395 * @return this {@code CacheBuilder} instance (for chaining) 396 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 397 * @throws IllegalStateException if a concurrency level was already set 398 */ 399 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { 400 checkState( 401 this.concurrencyLevel == UNSET_INT, 402 "concurrency level was already set to %s", 403 this.concurrencyLevel); 404 checkArgument(concurrencyLevel > 0); 405 this.concurrencyLevel = concurrencyLevel; 406 return this; 407 } 408 409 int getConcurrencyLevel() { 410 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; 411 } 412 413 /** 414 * Specifies the maximum number of entries the cache may contain. 415 * 416 * <p>Note that the cache <b>may evict an entry before this limit is exceeded</b>. For example, in 417 * the current implementation, when {@code concurrencyLevel} is greater than {@code 1}, each 418 * resulting segment inside the cache <i>independently</i> limits its own size to approximately 419 * {@code maximumSize / concurrencyLevel}. 420 * 421 * <p>When eviction is necessary, the cache evicts entries that are less likely to be used again. 422 * For example, the cache may evict an entry because it hasn't been used recently or very often. 423 * 424 * <p>If {@code maximumSize} is zero, elements will be evicted immediately after being loaded into 425 * cache. This can be useful in testing, or to disable caching temporarily. 426 * 427 * <p>This feature cannot be used in conjunction with {@link #maximumWeight}. 428 * 429 * @param maximumSize the maximum size of the cache 430 * @return this {@code CacheBuilder} instance (for chaining) 431 * @throws IllegalArgumentException if {@code maximumSize} is negative 432 * @throws IllegalStateException if a maximum size or weight was already set 433 */ 434 public CacheBuilder<K, V> maximumSize(long maximumSize) { 435 checkState( 436 this.maximumSize == UNSET_INT, "maximum size was already set to %s", this.maximumSize); 437 checkState( 438 this.maximumWeight == UNSET_INT, 439 "maximum weight was already set to %s", 440 this.maximumWeight); 441 checkState(this.weigher == null, "maximum size can not be combined with weigher"); 442 checkArgument(maximumSize >= 0, "maximum size must not be negative"); 443 this.maximumSize = maximumSize; 444 return this; 445 } 446 447 /** 448 * Specifies the maximum weight of entries the cache may contain. Weight is determined using the 449 * {@link Weigher} specified with {@link #weigher}, and use of this method requires a 450 * corresponding call to {@link #weigher} prior to calling {@link #build}. 451 * 452 * <p>Note that the cache <b>may evict an entry before this limit is exceeded</b>. For example, in 453 * the current implementation, when {@code concurrencyLevel} is greater than {@code 1}, each 454 * resulting segment inside the cache <i>independently</i> limits its own weight to approximately 455 * {@code maximumWeight / concurrencyLevel}. 456 * 457 * <p>When eviction is necessary, the cache evicts entries that are less likely to be used again. 458 * For example, the cache may evict an entry because it hasn't been used recently or very often. 459 * 460 * <p>If {@code maximumWeight} is zero, elements will be evicted immediately after being loaded 461 * into cache. This can be useful in testing, or to disable caching temporarily. 462 * 463 * <p>Note that weight is only used to determine whether the cache is over capacity; it has no 464 * effect on selecting which entry should be evicted next. 465 * 466 * <p>This feature cannot be used in conjunction with {@link #maximumSize}. 467 * 468 * @param maximumWeight the maximum total weight of entries the cache may contain 469 * @return this {@code CacheBuilder} instance (for chaining) 470 * @throws IllegalArgumentException if {@code maximumWeight} is negative 471 * @throws IllegalStateException if a maximum weight or size was already set 472 * @since 11.0 473 */ 474 @GwtIncompatible // To be supported 475 public CacheBuilder<K, V> maximumWeight(long maximumWeight) { 476 checkState( 477 this.maximumWeight == UNSET_INT, 478 "maximum weight was already set to %s", 479 this.maximumWeight); 480 checkState( 481 this.maximumSize == UNSET_INT, "maximum size was already set to %s", this.maximumSize); 482 this.maximumWeight = maximumWeight; 483 checkArgument(maximumWeight >= 0, "maximum weight must not be negative"); 484 return this; 485 } 486 487 /** 488 * Specifies the weigher to use in determining the weight of entries. Entry weight is taken into 489 * consideration by {@link #maximumWeight(long)} when determining which entries to evict, and use 490 * of this method requires a corresponding call to {@link #maximumWeight(long)} prior to calling 491 * {@link #build}. Weights are measured and recorded when entries are inserted into the cache, and 492 * are thus effectively static during the lifetime of a cache entry. 493 * 494 * <p>When the weight of an entry is zero it will not be considered for size-based eviction 495 * (though it still may be evicted by other means). 496 * 497 * <p><b>Important note:</b> Instead of returning <em>this</em> as a {@code CacheBuilder} 498 * instance, this method returns {@code CacheBuilder<K1, V1>}. From this point on, either the 499 * original reference or the returned reference may be used to complete configuration and build 500 * the cache, but only the "generic" one is type-safe. That is, it will properly prevent you from 501 * building caches whose key or value types are incompatible with the types accepted by the 502 * weigher already provided; the {@code CacheBuilder} type cannot do this. For best results, 503 * simply use the standard method-chaining idiom, as illustrated in the documentation at top, 504 * configuring a {@code CacheBuilder} and building your {@link Cache} all in a single statement. 505 * 506 * <p><b>Warning:</b> if you ignore the above advice, and use this {@code CacheBuilder} to build a 507 * cache whose key or value type is incompatible with the weigher, you will likely experience a 508 * {@link ClassCastException} at some <i>undefined</i> point in the future. 509 * 510 * @param weigher the weigher to use in calculating the weight of cache entries 511 * @return this {@code CacheBuilder} instance (for chaining) 512 * @throws IllegalArgumentException if {@code size} is negative 513 * @throws IllegalStateException if a maximum size was already set 514 * @since 11.0 515 */ 516 @GwtIncompatible // To be supported 517 public <K1 extends K, V1 extends V> CacheBuilder<K1, V1> weigher( 518 Weigher<? super K1, ? super V1> weigher) { 519 checkState(this.weigher == null); 520 if (strictParsing) { 521 checkState( 522 this.maximumSize == UNSET_INT, 523 "weigher can not be combined with maximum size", 524 this.maximumSize); 525 } 526 527 // safely limiting the kinds of caches this can produce 528 @SuppressWarnings("unchecked") 529 CacheBuilder<K1, V1> me = (CacheBuilder<K1, V1>) this; 530 me.weigher = checkNotNull(weigher); 531 return me; 532 } 533 534 long getMaximumWeight() { 535 if (expireAfterWriteNanos == 0 || expireAfterAccessNanos == 0) { 536 return 0; 537 } 538 return (weigher == null) ? maximumSize : maximumWeight; 539 } 540 541 // Make a safe contravariant cast now so we don't have to do it over and over. 542 @SuppressWarnings("unchecked") 543 <K1 extends K, V1 extends V> Weigher<K1, V1> getWeigher() { 544 return (Weigher<K1, V1>) MoreObjects.firstNonNull(weigher, OneWeigher.INSTANCE); 545 } 546 547 /** 548 * Specifies that each key (not value) stored in the cache should be wrapped in a {@link 549 * WeakReference} (by default, strong references are used). 550 * 551 * <p><b>Warning:</b> when this method is used, the resulting cache will use identity ({@code ==}) 552 * comparison to determine equality of keys. Its {@link Cache#asMap} view will therefore 553 * technically violate the {@link Map} specification (in the same way that {@link IdentityHashMap} 554 * does). 555 * 556 * <p>Entries with keys that have been garbage collected may be counted in {@link Cache#size}, but 557 * will never be visible to read or write operations; such entries are cleaned up as part of the 558 * routine maintenance described in the class javadoc. 559 * 560 * @return this {@code CacheBuilder} instance (for chaining) 561 * @throws IllegalStateException if the key strength was already set 562 */ 563 @GwtIncompatible // java.lang.ref.WeakReference 564 public CacheBuilder<K, V> weakKeys() { 565 return setKeyStrength(Strength.WEAK); 566 } 567 568 CacheBuilder<K, V> setKeyStrength(Strength strength) { 569 checkState(keyStrength == null, "Key strength was already set to %s", keyStrength); 570 keyStrength = checkNotNull(strength); 571 return this; 572 } 573 574 Strength getKeyStrength() { 575 return MoreObjects.firstNonNull(keyStrength, Strength.STRONG); 576 } 577 578 /** 579 * Specifies that each value (not key) stored in the cache should be wrapped in a {@link 580 * WeakReference} (by default, strong references are used). 581 * 582 * <p>Weak values will be garbage collected once they are weakly reachable. This makes them a poor 583 * candidate for caching; consider {@link #softValues} instead. 584 * 585 * <p><b>Note:</b> when this method is used, the resulting cache will use identity ({@code ==}) 586 * comparison to determine equality of values. 587 * 588 * <p>Entries with values that have been garbage collected may be counted in {@link Cache#size}, 589 * but will never be visible to read or write operations; such entries are cleaned up as part of 590 * the routine maintenance described in the class javadoc. 591 * 592 * @return this {@code CacheBuilder} instance (for chaining) 593 * @throws IllegalStateException if the value strength was already set 594 */ 595 @GwtIncompatible // java.lang.ref.WeakReference 596 public CacheBuilder<K, V> weakValues() { 597 return setValueStrength(Strength.WEAK); 598 } 599 600 /** 601 * Specifies that each value (not key) stored in the cache should be wrapped in a {@link 602 * SoftReference} (by default, strong references are used). Softly-referenced objects will be 603 * garbage-collected in a <i>globally</i> least-recently-used manner, in response to memory 604 * demand. 605 * 606 * <p><b>Warning:</b> in most circumstances it is better to set a per-cache {@linkplain 607 * #maximumSize(long) maximum size} instead of using soft references. You should only use this 608 * method if you are well familiar with the practical consequences of soft references. 609 * 610 * <p><b>Note:</b> when this method is used, the resulting cache will use identity ({@code ==}) 611 * comparison to determine equality of values. 612 * 613 * <p>Entries with values that have been garbage collected may be counted in {@link Cache#size}, 614 * but will never be visible to read or write operations; such entries are cleaned up as part of 615 * the routine maintenance described in the class javadoc. 616 * 617 * @return this {@code CacheBuilder} instance (for chaining) 618 * @throws IllegalStateException if the value strength was already set 619 */ 620 @GwtIncompatible // java.lang.ref.SoftReference 621 public CacheBuilder<K, V> softValues() { 622 return setValueStrength(Strength.SOFT); 623 } 624 625 CacheBuilder<K, V> setValueStrength(Strength strength) { 626 checkState(valueStrength == null, "Value strength was already set to %s", valueStrength); 627 valueStrength = checkNotNull(strength); 628 return this; 629 } 630 631 Strength getValueStrength() { 632 return MoreObjects.firstNonNull(valueStrength, Strength.STRONG); 633 } 634 635 /** 636 * Specifies that each entry should be automatically removed from the cache once a fixed duration 637 * has elapsed after the entry's creation, or the most recent replacement of its value. 638 * 639 * <p>When {@code duration} is zero, this method hands off to {@link #maximumSize(long) 640 * maximumSize}{@code (0)}, ignoring any otherwise-specified maximum size or weight. This can be 641 * useful in testing, or to disable caching temporarily without a code change. 642 * 643 * <p>Expired entries may be counted in {@link Cache#size}, but will never be visible to read or 644 * write operations. Expired entries are cleaned up as part of the routine maintenance described 645 * in the class javadoc. 646 * 647 * @param duration the length of time after an entry is created that it should be automatically 648 * removed 649 * @param unit the unit that {@code duration} is expressed in 650 * @return this {@code CacheBuilder} instance (for chaining) 651 * @throws IllegalArgumentException if {@code duration} is negative 652 * @throws IllegalStateException if the time to live or time to idle was already set 653 */ 654 @SuppressWarnings("GoodTime") // should accept a java.time.Duration 655 public CacheBuilder<K, V> expireAfterWrite(long duration, TimeUnit unit) { 656 checkState( 657 expireAfterWriteNanos == UNSET_INT, 658 "expireAfterWrite was already set to %s ns", 659 expireAfterWriteNanos); 660 checkArgument(duration >= 0, "duration cannot be negative: %s %s", duration, unit); 661 this.expireAfterWriteNanos = unit.toNanos(duration); 662 return this; 663 } 664 665 long getExpireAfterWriteNanos() { 666 return (expireAfterWriteNanos == UNSET_INT) ? DEFAULT_EXPIRATION_NANOS : expireAfterWriteNanos; 667 } 668 669 /** 670 * Specifies that each entry should be automatically removed from the cache once a fixed duration 671 * has elapsed after the entry's creation, the most recent replacement of its value, or its last 672 * access. Access time is reset by all cache read and write operations (including {@code 673 * Cache.asMap().get(Object)} and {@code Cache.asMap().put(K, V)}), but not by {@code 674 * containsKey(Object)}, nor by operations on the collection-views of {@link Cache#asMap}. So, for 675 * example, iterating through {@code Cache.asMap().entrySet()} does not reset access time for the 676 * entries you retrieve. 677 * 678 * <p>When {@code duration} is zero, this method hands off to {@link #maximumSize(long) 679 * maximumSize}{@code (0)}, ignoring any otherwise-specified maximum size or weight. This can be 680 * useful in testing, or to disable caching temporarily without a code change. 681 * 682 * <p>Expired entries may be counted in {@link Cache#size}, but will never be visible to read or 683 * write operations. Expired entries are cleaned up as part of the routine maintenance described 684 * in the class javadoc. 685 * 686 * @param duration the length of time after an entry is last accessed that it should be 687 * automatically removed 688 * @param unit the unit that {@code duration} is expressed in 689 * @return this {@code CacheBuilder} instance (for chaining) 690 * @throws IllegalArgumentException if {@code duration} is negative 691 * @throws IllegalStateException if the time to idle or time to live was already set 692 */ 693 @SuppressWarnings("GoodTime") // should accept a java.time.Duration 694 public CacheBuilder<K, V> expireAfterAccess(long duration, TimeUnit unit) { 695 checkState( 696 expireAfterAccessNanos == UNSET_INT, 697 "expireAfterAccess was already set to %s ns", 698 expireAfterAccessNanos); 699 checkArgument(duration >= 0, "duration cannot be negative: %s %s", duration, unit); 700 this.expireAfterAccessNanos = unit.toNanos(duration); 701 return this; 702 } 703 704 long getExpireAfterAccessNanos() { 705 return (expireAfterAccessNanos == UNSET_INT) 706 ? DEFAULT_EXPIRATION_NANOS 707 : expireAfterAccessNanos; 708 } 709 710 /** 711 * Specifies that active entries are eligible for automatic refresh once a fixed duration has 712 * elapsed after the entry's creation, or the most recent replacement of its value. The semantics 713 * of refreshes are specified in {@link LoadingCache#refresh}, and are performed by calling {@link 714 * CacheLoader#reload}. 715 * 716 * <p>As the default implementation of {@link CacheLoader#reload} is synchronous, it is 717 * recommended that users of this method override {@link CacheLoader#reload} with an asynchronous 718 * implementation; otherwise refreshes will be performed during unrelated cache read and write 719 * operations. 720 * 721 * <p>Currently automatic refreshes are performed when the first stale request for an entry 722 * occurs. The request triggering refresh will make a blocking call to {@link CacheLoader#reload} 723 * and immediately return the new value if the returned future is complete, and the old value 724 * otherwise. 725 * 726 * <p><b>Note:</b> <i>all exceptions thrown during refresh will be logged and then swallowed</i>. 727 * 728 * @param duration the length of time after an entry is created that it should be considered 729 * stale, and thus eligible for refresh 730 * @param unit the unit that {@code duration} is expressed in 731 * @return this {@code CacheBuilder} instance (for chaining) 732 * @throws IllegalArgumentException if {@code duration} is negative 733 * @throws IllegalStateException if the refresh interval was already set 734 * @since 11.0 735 */ 736 @GwtIncompatible // To be supported (synchronously). 737 @SuppressWarnings("GoodTime") // should accept a java.time.Duration 738 public CacheBuilder<K, V> refreshAfterWrite(long duration, TimeUnit unit) { 739 checkNotNull(unit); 740 checkState(refreshNanos == UNSET_INT, "refresh was already set to %s ns", refreshNanos); 741 checkArgument(duration > 0, "duration must be positive: %s %s", duration, unit); 742 this.refreshNanos = unit.toNanos(duration); 743 return this; 744 } 745 746 long getRefreshNanos() { 747 return (refreshNanos == UNSET_INT) ? DEFAULT_REFRESH_NANOS : refreshNanos; 748 } 749 750 /** 751 * Specifies a nanosecond-precision time source for this cache. By default, {@link 752 * System#nanoTime} is used. 753 * 754 * <p>The primary intent of this method is to facilitate testing of caches with a fake or mock 755 * time source. 756 * 757 * @return this {@code CacheBuilder} instance (for chaining) 758 * @throws IllegalStateException if a ticker was already set 759 */ 760 public CacheBuilder<K, V> ticker(Ticker ticker) { 761 checkState(this.ticker == null); 762 this.ticker = checkNotNull(ticker); 763 return this; 764 } 765 766 Ticker getTicker(boolean recordsTime) { 767 if (ticker != null) { 768 return ticker; 769 } 770 return recordsTime ? Ticker.systemTicker() : NULL_TICKER; 771 } 772 773 /** 774 * Specifies a listener instance that caches should notify each time an entry is removed for any 775 * {@linkplain RemovalCause reason}. Each cache created by this builder will invoke this listener 776 * as part of the routine maintenance described in the class documentation above. 777 * 778 * <p><b>Warning:</b> after invoking this method, do not continue to use <i>this</i> cache builder 779 * reference; instead use the reference this method <i>returns</i>. At runtime, these point to the 780 * same instance, but only the returned reference has the correct generic type information so as 781 * to ensure type safety. For best results, use the standard method-chaining idiom illustrated in 782 * the class documentation above, configuring a builder and building your cache in a single 783 * statement. Failure to heed this advice can result in a {@link ClassCastException} being thrown 784 * by a cache operation at some <i>undefined</i> point in the future. 785 * 786 * <p><b>Warning:</b> any exception thrown by {@code listener} will <i>not</i> be propagated to 787 * the {@code Cache} user, only logged via a {@link Logger}. 788 * 789 * @return the cache builder reference that should be used instead of {@code this} for any 790 * remaining configuration and cache building 791 * @return this {@code CacheBuilder} instance (for chaining) 792 * @throws IllegalStateException if a removal listener was already set 793 */ 794 @CheckReturnValue 795 public <K1 extends K, V1 extends V> CacheBuilder<K1, V1> removalListener( 796 RemovalListener<? super K1, ? super V1> listener) { 797 checkState(this.removalListener == null); 798 799 // safely limiting the kinds of caches this can produce 800 @SuppressWarnings("unchecked") 801 CacheBuilder<K1, V1> me = (CacheBuilder<K1, V1>) this; 802 me.removalListener = checkNotNull(listener); 803 return me; 804 } 805 806 // Make a safe contravariant cast now so we don't have to do it over and over. 807 @SuppressWarnings("unchecked") 808 <K1 extends K, V1 extends V> RemovalListener<K1, V1> getRemovalListener() { 809 return (RemovalListener<K1, V1>) 810 MoreObjects.firstNonNull(removalListener, NullListener.INSTANCE); 811 } 812 813 /** 814 * Enable the accumulation of {@link CacheStats} during the operation of the cache. Without this 815 * {@link Cache#stats} will return zero for all statistics. Note that recording stats requires 816 * bookkeeping to be performed with each operation, and thus imposes a performance penalty on 817 * cache operation. 818 * 819 * @return this {@code CacheBuilder} instance (for chaining) 820 * @since 12.0 (previously, stats collection was automatic) 821 */ 822 public CacheBuilder<K, V> recordStats() { 823 statsCounterSupplier = CACHE_STATS_COUNTER; 824 return this; 825 } 826 827 boolean isRecordingStats() { 828 return statsCounterSupplier == CACHE_STATS_COUNTER; 829 } 830 831 Supplier<? extends StatsCounter> getStatsCounterSupplier() { 832 return statsCounterSupplier; 833 } 834 835 /** 836 * Builds a cache, which either returns an already-loaded value for a given key or atomically 837 * computes or retrieves it using the supplied {@code CacheLoader}. If another thread is currently 838 * loading the value for this key, simply waits for that thread to finish and returns its loaded 839 * value. Note that multiple threads can concurrently load values for distinct keys. 840 * 841 * <p>This method does not alter the state of this {@code CacheBuilder} instance, so it can be 842 * invoked again to create multiple independent caches. 843 * 844 * @param loader the cache loader used to obtain new values 845 * @return a cache having the requested features 846 */ 847 public <K1 extends K, V1 extends V> LoadingCache<K1, V1> build( 848 CacheLoader<? super K1, V1> loader) { 849 checkWeightWithWeigher(); 850 return new LocalCache.LocalLoadingCache<>(this, loader); 851 } 852 853 /** 854 * Builds a cache which does not automatically load values when keys are requested. 855 * 856 * <p>Consider {@link #build(CacheLoader)} instead, if it is feasible to implement a {@code 857 * CacheLoader}. 858 * 859 * <p>This method does not alter the state of this {@code CacheBuilder} instance, so it can be 860 * invoked again to create multiple independent caches. 861 * 862 * @return a cache having the requested features 863 * @since 11.0 864 */ 865 public <K1 extends K, V1 extends V> Cache<K1, V1> build() { 866 checkWeightWithWeigher(); 867 checkNonLoadingCache(); 868 return new LocalCache.LocalManualCache<>(this); 869 } 870 871 private void checkNonLoadingCache() { 872 checkState(refreshNanos == UNSET_INT, "refreshAfterWrite requires a LoadingCache"); 873 } 874 875 private void checkWeightWithWeigher() { 876 if (weigher == null) { 877 checkState(maximumWeight == UNSET_INT, "maximumWeight requires weigher"); 878 } else { 879 if (strictParsing) { 880 checkState(maximumWeight != UNSET_INT, "weigher requires maximumWeight"); 881 } else { 882 if (maximumWeight == UNSET_INT) { 883 logger.log(Level.WARNING, "ignoring weigher specified without maximumWeight"); 884 } 885 } 886 } 887 } 888 889 /** 890 * Returns a string representation for this CacheBuilder instance. The exact form of the returned 891 * string is not specified. 892 */ 893 @Override 894 public String toString() { 895 MoreObjects.ToStringHelper s = MoreObjects.toStringHelper(this); 896 if (initialCapacity != UNSET_INT) { 897 s.add("initialCapacity", initialCapacity); 898 } 899 if (concurrencyLevel != UNSET_INT) { 900 s.add("concurrencyLevel", concurrencyLevel); 901 } 902 if (maximumSize != UNSET_INT) { 903 s.add("maximumSize", maximumSize); 904 } 905 if (maximumWeight != UNSET_INT) { 906 s.add("maximumWeight", maximumWeight); 907 } 908 if (expireAfterWriteNanos != UNSET_INT) { 909 s.add("expireAfterWrite", expireAfterWriteNanos + "ns"); 910 } 911 if (expireAfterAccessNanos != UNSET_INT) { 912 s.add("expireAfterAccess", expireAfterAccessNanos + "ns"); 913 } 914 if (keyStrength != null) { 915 s.add("keyStrength", Ascii.toLowerCase(keyStrength.toString())); 916 } 917 if (valueStrength != null) { 918 s.add("valueStrength", Ascii.toLowerCase(valueStrength.toString())); 919 } 920 if (keyEquivalence != null) { 921 s.addValue("keyEquivalence"); 922 } 923 if (valueEquivalence != null) { 924 s.addValue("valueEquivalence"); 925 } 926 if (removalListener != null) { 927 s.addValue("removalListener"); 928 } 929 return s.toString(); 930 } 931}