/external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ |
H A D | GenericMapMaker.java | 63 * See {@link MapMaker#concurrencyLevel}. 65 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
|
H A D | MapMaker.java | 205 public MapMaker concurrencyLevel(int concurrencyLevel) { argument 206 if (concurrencyLevel < 1) { 209 // GWT technically only supports concurrencyLevel == 1, but we silently
|
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
H A D | OkHttpAsync.java | 43 private int concurrencyLevel; field in class:OkHttpAsync 47 concurrencyLevel = benchmark.concurrencyLevel; 52 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel, 53 benchmark.concurrencyLevel, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()))); 92 return requestsInFlight.get() < (concurrencyLevel + targetBacklog);
|
H A D | Benchmark.java | 57 int concurrencyLevel; field in class:Benchmark 148 return String.format("%s %s\nbodyByteCount=%s headerCount=%s concurrencyLevel=%s", 149 client, modifiers, bodyByteCount, headerCount, concurrencyLevel);
|
H A D | NettyHttpClient.java | 60 private int concurrencyLevel; field in class:NettyHttpClient 65 this.concurrencyLevel = benchmark.concurrencyLevel; 86 bootstrap.group(new NioEventLoopGroup(concurrencyLevel)) 97 } else if (totalChannels < concurrencyLevel) { 118 return activeChannels < concurrencyLevel;
|
/external/guava/guava/src/com/google/common/collect/ |
H A D | GenericMapMaker.java | 83 * See {@link MapMaker#concurrencyLevel}. 85 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
|
H A D | ComputingConcurrentHashMap.java | 384 concurrencyLevel, removalListener, this, computingFunction); 394 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, 397 expireAfterAccessNanos, maximumSize, concurrencyLevel, removalListener, delegate); 391 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 D | MapMaker.java | 61 * .concurrencyLevel(4) 118 int concurrencyLevel = UNSET_INT; field in class:MapMaker 236 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 240 public MapMaker concurrencyLevel(int concurrencyLevel) { argument 241 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", 242 this.concurrencyLevel); 243 checkArgument(concurrencyLevel > 0); 244 this.concurrencyLevel = concurrencyLevel; [all...] |
H A D | MapMakerInternalMap.java | 153 final int concurrencyLevel; field in class:MapMakerInternalMap 196 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS); 223 // && (concurrencyLevel > maximumSize || segmentCount > concurrencyLevel) 226 while (segmentCount < concurrencyLevel 3889 concurrencyLevel, removalListener, this); 3907 final int concurrencyLevel; field in class:MapMakerInternalMap.AbstractSerializationProxy 3915 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, 3924 this.concurrencyLevel = concurrencyLevel; 3912 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 3985 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/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/ |
H A D | LocaleObjectCache.java | 21 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { argument 22 _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel);
|
/external/guava/guava/src/com/google/common/cache/ |
H A D | CacheBuilderSpec.java | 43 * <li>{@code concurrencyLevel=[integer]}: sets {@link CacheBuilder#concurrencyLevel}. 100 .put("concurrencyLevel", new ConcurrencyLevelParser()) 114 @VisibleForTesting Integer concurrencyLevel; field in class:CacheBuilderSpec 180 if (concurrencyLevel != null) { 181 builder.concurrencyLevel(concurrencyLevel); 245 concurrencyLevel, 266 && Objects.equal(concurrencyLevel, that.concurrencyLevel) [all...] |
H A D | CacheBuilder.java | 221 int concurrencyLevel = UNSET_INT; field in class:CacheBuilder 365 * uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction 371 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 374 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { argument 375 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", 376 this.concurrencyLevel); 377 checkArgument(concurrencyLevel > 0); 378 this.concurrencyLevel = concurrencyLevel; [all...] |
H A D | LocalCache.java | 178 final int concurrencyLevel; field in class:LocalCache 240 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS); 269 // Find the lowest power-of-two segmentCount that exceeds concurrencyLevel, unless 276 while (segmentCount < concurrencyLevel 4568 final int concurrencyLevel; field in class:LocalCache.ManualSerializationProxy 4585 cache.concurrencyLevel, 4595 Weigher<K, V> weigher, int concurrencyLevel, 4606 this.concurrencyLevel = concurrencyLevel; 4619 .concurrencyLevel(concurrencyLeve 4591 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-tests/test/com/google/common/cache/ |
H A D | CacheBuilderFactory.java | 150 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 D | LocalCacheTest.java | 168 assertEquals(4, map.concurrencyLevel); 233 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { argument 235 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); 274 int concurrencyLevel, int initialCapacity, int segmentSize) { 276 createCacheBuilder().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); 283 // vary maximumSize wrt concurrencyLevel 307 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { argument 309 .concurrencyLevel(concurrencyLeve 273 checkInitialCapacity( int concurrencyLevel, int initialCapacity, int segmentSize) argument [all...] |
/external/guava/guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/ |
H A D | CacheBuilder.java | 215 int concurrencyLevel = UNSET_INT; field in class:CacheBuilder 297 * uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction 303 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 306 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { argument 307 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", 308 this.concurrencyLevel); 309 checkArgument(concurrencyLevel > 0); 310 this.concurrencyLevel = concurrencyLevel; [all...] |
/external/guava/guava-tests/test/com/google/common/collect/ |
H A D | MapMakerInternalMapTest.java | 93 assertEquals(4, map.concurrencyLevel); 138 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { argument 140 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel)); 179 int concurrencyLevel, int initialCapacity, int segmentSize) { 181 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); 188 // vary maximumSize wrt concurrencyLevel 212 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) { argument 214 .concurrencyLevel(concurrencyLeve 178 checkInitialCapacity( int concurrencyLevel, int initialCapacity, int segmentSize) argument [all...] |
/external/owasp/sanitizer/distrib/lib/ |
H A D | guava.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/common/ com/google/common/collect/ ... |
/external/owasp/sanitizer/lib/guava-libraries/ |
H A D | guava.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/common/ com/google/common/collect/ ... |
/external/vogar/lib/ |
H A D | guava.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/common/ com/google/common/annotations/ ... |
/external/robolectric/lib/main/ |
H A D | android.jar | META-INF/ META-INF/MANIFEST.MF com/ com/android/ com/android/internal/ com/android/internal/util/ ... |