/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 | SynchronousHttpClient.java | 32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel,
|
H A D | NettyHttpClient.java | 59 private int concurrencyLevel; field in class:NettyHttpClient 64 this.concurrencyLevel = benchmark.concurrencyLevel; 85 bootstrap.group(new NioEventLoopGroup(concurrencyLevel)) 96 } else if (totalChannels < concurrencyLevel) { 117 return activeChannels < concurrencyLevel;
|
/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/guava/guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/ |
H A D | CacheBuilder.java | 214 int concurrencyLevel = UNSET_INT; field in class:CacheBuilder 296 * uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction 302 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 305 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { argument 306 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", 307 this.concurrencyLevel); 308 checkArgument(concurrencyLevel > 0); 309 this.concurrencyLevel = concurrencyLevel; [all...] |
/external/guava/guava/src/com/google/common/cache/ |
H A D | CacheBuilder.java | 220 int concurrencyLevel = UNSET_INT; field in class:CacheBuilder 364 * uncommon to specify {@code concurrencyLevel(1)} in order to achieve more deterministic eviction 370 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 373 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { argument 374 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", 375 this.concurrencyLevel); 376 checkArgument(concurrencyLevel > 0); 377 this.concurrencyLevel = concurrencyLevel; [all...] |
H A D | CacheBuilderSpec.java | 44 * <li>{@code concurrencyLevel=[integer]}: sets {@link CacheBuilder#concurrencyLevel}. 101 .put("concurrencyLevel", new ConcurrencyLevelParser()) 115 @VisibleForTesting Integer concurrencyLevel; field in class:CacheBuilderSpec 181 if (concurrencyLevel != null) { 182 builder.concurrencyLevel(concurrencyLevel); 246 concurrencyLevel, 267 && Objects.equal(concurrencyLevel, that.concurrencyLevel) [all...] |
/external/guava/guava/src/com/google/common/collect/ |
H A D | MapMaker.java | 60 * .concurrencyLevel(4) 117 int concurrencyLevel = UNSET_INT; field in class:MapMaker 235 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive 239 public MapMaker concurrencyLevel(int concurrencyLevel) { argument 240 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", 241 this.concurrencyLevel); 242 checkArgument(concurrencyLevel > 0); 243 this.concurrencyLevel = concurrencyLevel; [all...] |
H A D | GenericMapMaker.java | 83 * See {@link MapMaker#concurrencyLevel}. 85 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
|
/external/guava/guava-tests/test/com/google/common/cache/ |
H A D | CacheBuilderSpecTest.java | 42 assertNull(spec.concurrencyLevel); 55 assertNull(spec.concurrencyLevel); 77 assertNull(spec.concurrencyLevel); 99 assertNull(spec.concurrencyLevel); 127 CacheBuilderSpec spec = parse("concurrencyLevel=32"); 131 assertEquals(32, spec.concurrencyLevel.intValue()); 137 CacheBuilder.newBuilder().concurrencyLevel(32), CacheBuilder.from(spec)); 142 parse("concurrencyLevel=10, concurrencyLevel=20"); 154 assertNull(spec.concurrencyLevel); [all...] |
H A D | CacheEvictionTest.java | 67 .concurrencyLevel(1) 82 .concurrencyLevel(1) 138 .concurrencyLevel(1) 166 .concurrencyLevel(1) 182 .concurrencyLevel(1) 214 .concurrencyLevel(1) 257 .concurrencyLevel(1) 280 .concurrencyLevel(1)
|
H A D | CacheBuilderFactory.java | 151 Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize, 156 if (concurrencyLevel != null) { 157 builder.concurrencyLevel(concurrencyLevel); 150 createCacheBuilder( Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize, DurationSpec expireAfterWrite, DurationSpec expireAfterAccess, DurationSpec refresh, Strength keyStrength, Strength valueStrength) argument
|
H A D | LocalCacheTest.java | 169 assertEquals(4, map.concurrencyLevel); 234 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { argument 236 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); 275 int concurrencyLevel, int initialCapacity, int segmentSize) { 277 createCacheBuilder().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); 284 // vary maximumSize wrt concurrencyLevel 308 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { argument 310 .concurrencyLevel(concurrencyLeve 274 checkInitialCapacity( int concurrencyLevel, int initialCapacity, int segmentSize) argument [all...] |
H A D | CacheBuilderTest.java | 121 builder.concurrencyLevel(0); 127 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16); 130 builder.concurrencyLevel(16); 138 .concurrencyLevel(1) 145 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE); 400 .concurrencyLevel(1) 458 .concurrencyLevel(20) 559 .concurrencyLevel(2)
|
/external/guava/guava-gwt/test-super/com/google/common/cache/super/com/google/common/cache/ |
H A D | CacheBuilderTest.java | 74 builder.concurrencyLevel(0); 80 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16); 83 builder.concurrencyLevel(16); 89 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE);
|
/external/icu/android_icu4j/src/main/java/android/icu/impl/locale/ |
H A D | LocaleObjectCache.java | 27 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { argument 28 _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel);
|
/external/icu/icu4j/eclipse-build/plugins.template/com.ibm.icu.base/src/com/ibm/icu/impl/locale/ |
H A D | LocaleObjectCache.java | 23 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { argument 24 _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel);
|
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/ |
H A D | LocaleObjectCache.java | 23 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { argument 24 _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel);
|
/external/guava/guava-tests/benchmark/com/google/common/cache/ |
H A D | ChainBenchmark.java | 42 .concurrencyLevel(1), null);
|
H A D | SegmentBenchmark.java | 44 .concurrencyLevel(1)
|
H A D | LoadingCacheSingleThreadBenchmark.java | 57 .concurrencyLevel(segments)
|
/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/guava/guava-tests/benchmark/com/google/common/collect/ |
H A D | MapMakerSingleThreadBenchmark.java | 60 .concurrencyLevel(segments)
|
H A D | MapBenchmark.java | 113 .concurrencyLevel(1) 124 .concurrencyLevel(16)
|