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

123

/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
H A DOkHttpAsync.java43 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 DSynchronousHttpClient.java32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel,
H A DNettyHttpClient.java59 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 DGenericMapMaker.java63 * See {@link MapMaker#concurrencyLevel}.
65 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
H A DMapMaker.java205 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 DCacheBuilder.java214 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 DCacheBuilder.java220 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 DCacheBuilderSpec.java44 * <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 DMapMaker.java60 * .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 DGenericMapMaker.java83 * 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 DCacheBuilderSpecTest.java42 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 DCacheEvictionTest.java67 .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 DCacheBuilderFactory.java151 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 DLocalCacheTest.java169 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 DCacheBuilderTest.java121 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 DCacheBuilderTest.java74 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 DLocaleObjectCache.java27 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 DLocaleObjectCache.java23 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 DLocaleObjectCache.java23 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 DChainBenchmark.java42 .concurrencyLevel(1), null);
H A DSegmentBenchmark.java44 .concurrencyLevel(1)
H A DLoadingCacheSingleThreadBenchmark.java57 .concurrencyLevel(segments)
/external/guava/guava-tests/test/com/google/common/collect/
H A DMapMakerInternalMapTest.java93 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 DMapMakerSingleThreadBenchmark.java60 .concurrencyLevel(segments)
H A DMapBenchmark.java113 .concurrencyLevel(1)
124 .concurrencyLevel(16)

Completed in 1790 milliseconds

123