Searched defs:concurrencyLevel (Results 1 - 25 of 37) sorted by relevance

12

/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/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 DBenchmark.java57 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 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/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/guava/guava/src/com/google/common/collect/
H A DGenericMapMaker.java83 * See {@link MapMaker#concurrencyLevel}.
85 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); argument
H A DComputingConcurrentHashMap.java384 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 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 DMapMakerInternalMap.java153 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/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/src/com/google/common/cache/
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...]
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 DLocalCache.java175 final int concurrencyLevel; field in class:LocalCache
237 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
266 // Find the lowest power-of-two segmentCount that exceeds concurrencyLevel, unless
273 while (segmentCount < concurrencyLevel
4571 final int concurrencyLevel; field in class:LocalCache.ManualSerializationProxy
4588 cache.concurrencyLevel,
4598 Weigher<K, V> weigher, int concurrencyLevel,
4609 this.concurrencyLevel = concurrencyLevel;
4622 .concurrencyLevel(concurrencyLeve
4594 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 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...]
/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-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/testng/lib-supplied/
H A Dguice-2.0.jarMETA-INF/ META-INF/MANIFEST.MF LICENSE NOTICE org/ org/testng/ org/testng/guice/ org/testng/ ...
/external/owasp/sanitizer/distrib/lib/
H A Dguava.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/common/ com/google/common/collect/ ...
/external/owasp/sanitizer/lib/guava-libraries/
H A Dguava.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/common/ com/google/common/collect/ ...
/external/guice/lib/
H A Dguava-16.0.1.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ...
/external/dagger2/lib/
H A Dauto-value-1.4.1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/auto/ com/google/auto/value/ ...
/external/annotation-tools/annotation-file-utilities/lib/
H A Dguava-20.0.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ...

Completed in 1904 milliseconds

12