Searched refs:concurrencyLevel (Results 1 - 20 of 20) sorted by relevance

/external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/
H A DGenericMapMaker.java60 * See {@link MapMaker#concurrencyLevel}.
62 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
H A DMapMaker.java220 public MapMaker concurrencyLevel(int concurrencyLevel) { argument
221 if (concurrencyLevel < 1) {
224 // GWT technically only supports concurrencyLevel == 1, but we silently
/external/guava/guava/src/com/google/common/cache/
H A DCacheBuilder.java204 int concurrencyLevel = UNSET_INT; field in class:CacheBuilder
314 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
317 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { argument
318 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s",
319 this.concurrencyLevel);
320 checkArgument(concurrencyLevel > 0);
321 this.concurrencyLevel = concurrencyLevel;
326 return (concurrencyLevel
[all...]
H A DLocalCache.java173 final int concurrencyLevel; field in class:LocalCache
234 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
265 // && (concurrencyLevel > maxWeight || segmentCount > concurrencyLevel)
268 while (segmentCount < concurrencyLevel
4595 final int concurrencyLevel; field in class:LocalCache.ManualSerializationProxy
4612 cache.concurrencyLevel,
4622 Weigher<K, V> weigher, int concurrencyLevel,
4633 this.concurrencyLevel = concurrencyLevel;
4618 ManualSerializationProxy( Strength keyStrength, Strength valueStrength, Equivalence<Object> keyEquivalence, Equivalence<Object> valueEquivalence, long expireAfterWriteNanos, long expireAfterAccessNanos, long maxWeight, Weigher<K, V> weigher, int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, Ticker ticker, CacheLoader<? super K, V> loader) argument
[all...]
/external/guava/guava/src/com/google/common/collect/
H A DMapMaker.java62 * .concurrencyLevel(4)
124 int concurrencyLevel = UNSET_INT; field in class:MapMaker
266 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
270 public MapMaker concurrencyLevel(int concurrencyLevel) { argument
271 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s",
272 this.concurrencyLevel);
273 checkArgument(concurrencyLevel > 0);
274 this.concurrencyLevel = concurrencyLevel;
[all...]
H A DGenericMapMaker.java86 * See {@link MapMaker#concurrencyLevel}.
88 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
H A DComputingConcurrentHashMap.java415 concurrencyLevel, removalListener, this, computingFunction);
425 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener,
428 expireAfterAccessNanos, maximumSize, concurrencyLevel, removalListener, delegate);
422 ComputingSerializationProxy(Strength keyStrength, Strength valueStrength, Equivalence<Object> keyEquivalence, Equivalence<Object> valueEquivalence, long expireAfterWriteNanos, long expireAfterAccessNanos, int maximumSize, int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, ConcurrentMap<K, V> delegate, Function<? super K, ? extends V> computingFunction) argument
H A DMapMakerInternalMap.java154 final int concurrencyLevel; field in class:MapMakerInternalMap
197 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
224 // && (concurrencyLevel > maximumSize || segmentCount > concurrencyLevel)
227 while (segmentCount < concurrencyLevel
3940 concurrencyLevel, removalListener, this);
3958 final int concurrencyLevel; field in class:MapMakerInternalMap.AbstractSerializationProxy
3966 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener,
3975 this.concurrencyLevel = concurrencyLevel;
3963 AbstractSerializationProxy(Strength keyStrength, Strength valueStrength, Equivalence<Object> keyEquivalence, Equivalence<Object> valueEquivalence, long expireAfterWriteNanos, long expireAfterAccessNanos, int maximumSize, int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, ConcurrentMap<K, V> delegate) argument
4037 SerializationProxy(Strength keyStrength, Strength valueStrength, Equivalence<Object> keyEquivalence, Equivalence<Object> valueEquivalence, long expireAfterWriteNanos, long expireAfterAccessNanos, int maximumSize, int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, ConcurrentMap<K, V> delegate) argument
[all...]
/external/guava/guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/
H A DCacheBuilder.java51 private int concurrencyLevel = -1; field in class:CacheBuilder
73 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { argument
74 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s",
75 this.concurrencyLevel);
76 checkArgument(concurrencyLevel > 0);
77 // GWT technically only supports concurrencyLevel == 1, but we silently
79 this.concurrencyLevel = concurrencyLevel;
/external/guava/guava-tests/test/com/google/common/cache/
H A DCacheEvictionTest.java67 .concurrencyLevel(1)
82 .concurrencyLevel(1)
151 .concurrencyLevel(1)
167 .concurrencyLevel(1)
199 .concurrencyLevel(1)
242 .concurrencyLevel(1)
265 .concurrencyLevel(1)
H A DCacheBuilderFactory.java150 Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize,
155 if (concurrencyLevel != null) {
156 builder.concurrencyLevel(concurrencyLevel);
149 createCacheBuilder( Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize, DurationSpec expireAfterWrite, DurationSpec expireAfterAccess, DurationSpec refresh, Strength keyStrength, Strength valueStrength) argument
H A DLocalCacheTest.java139 assertEquals(4, map.concurrencyLevel);
204 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { argument
206 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel));
245 int concurrencyLevel, int initialCapacity, int segmentSize) {
247 createCacheBuilder().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity));
254 // vary maximumSize wrt concurrencyLevel
278 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { argument
280 .concurrencyLevel(concurrencyLeve
244 checkInitialCapacity( int concurrencyLevel, int initialCapacity, int segmentSize) argument
[all...]
H A DCacheBuilderTest.java122 builder.concurrencyLevel(0);
128 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16);
131 builder.concurrencyLevel(16);
139 .concurrencyLevel(1)
146 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE);
407 .concurrencyLevel(1)
465 .concurrencyLevel(20)
565 .concurrencyLevel(2)
H A DLocalLoadingCacheTest.java84 .concurrencyLevel(1)
144 .concurrencyLevel(1);
183 .concurrencyLevel(1)
266 .concurrencyLevel(1)
H A DCacheExpirationTest.java254 .concurrencyLevel(1)
306 .concurrencyLevel(1)
353 .concurrencyLevel(1)
H A DCacheLoadingTest.java1661 .concurrencyLevel(1)
1685 .concurrencyLevel(1)
/external/guava/guava-tests/test/com/google/common/collect/
H A DMapMakerInternalMapTest.java93 assertEquals(4, map.concurrencyLevel);
157 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { argument
159 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel));
198 int concurrencyLevel, int initialCapacity, int segmentSize) {
200 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity));
207 // vary maximumSize wrt concurrencyLevel
231 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) { argument
233 .concurrencyLevel(concurrencyLeve
197 checkInitialCapacity( int concurrencyLevel, int initialCapacity, int segmentSize) argument
[all...]
H A DMapMakerTest.java56 .concurrencyLevel(1)
113 .concurrencyLevel(20)
H A DComputingConcurrentHashMapTest.java113 makeComputingMap(maker.concurrencyLevel(1), computingFunction);
168 MapMaker maker = createMapMaker().concurrencyLevel(1);
197 MapMaker maker = createMapMaker().concurrencyLevel(1);
H A DConcurrentHashMultisetTest.java532 .concurrencyLevel(1)

Completed in 223 milliseconds