Home
last modified time | relevance | path

Searched refs:concurrencyLevel (Results 1 – 25 of 49) sorted by relevance

12

/external/guava/guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/
DCacheBuilder.java214 int concurrencyLevel = UNSET_INT; field in CacheBuilder
305 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
306 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", in concurrencyLevel()
307 this.concurrencyLevel); in concurrencyLevel()
308 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
309 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
314 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
593 if (concurrencyLevel != UNSET_INT) { in toString()
594 s.add("concurrencyLevel", concurrencyLevel); in toString()
/external/guava/guava-tests/test/com/google/common/cache/
DCacheBuilderSpecTest.java42 assertNull(spec.concurrencyLevel); in testParse_empty()
55 assertNull(spec.concurrencyLevel); in testParse_initialCapacity()
77 assertNull(spec.concurrencyLevel); in testParse_maximumSize()
99 assertNull(spec.concurrencyLevel); in testParse_maximumWeight()
131 assertEquals(32, spec.concurrencyLevel.intValue()); in testParse_concurrencyLevel()
137 CacheBuilder.newBuilder().concurrencyLevel(32), CacheBuilder.from(spec)); in testParse_concurrencyLevel()
154 assertNull(spec.concurrencyLevel); in testParse_weakKeys()
186 assertNull(spec.concurrencyLevel); in testParse_softValues()
209 assertNull(spec.concurrencyLevel); in testParse_weakValues()
262 assertNull(spec.concurrencyLevel); in testParse_writeExpirationDays()
[all …]
DCacheEvictionTest.java67 .concurrencyLevel(1) in testEviction_maxSizeOneSegment()
82 .concurrencyLevel(1) in testEviction_maxWeightOneSegment()
138 .concurrencyLevel(1) in testEviction_overflow()
166 .concurrencyLevel(1) in testUpdateRecency_onInvalidate()
182 .concurrencyLevel(1) in testEviction_lru()
214 .concurrencyLevel(1) in testEviction_weightedLru()
257 .concurrencyLevel(1) in testEviction_overweight()
280 .concurrencyLevel(1) in testEviction_invalidateAll()
DLocalCacheTest.java169 assertEquals(4, map.concurrencyLevel); in testDefaults()
234 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
236 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
275 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
277 createCacheBuilder().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkInitialCapacity()
308 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { in checkMaximumSize() argument
310 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
322 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
452 makeLocalCache(builder.concurrencyLevel(1)); in testRecordReadOnCompute()
506 CacheBuilder<Object, Object> builder = createCacheBuilder().concurrencyLevel(1); in testComputePartiallyCollectedKey()
[all …]
DCacheBuilderTest.java121 builder.concurrencyLevel(0); in testConcurrencyLevel_zero()
127 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16); in testConcurrencyLevel_setTwice()
130 builder.concurrencyLevel(16); in testConcurrencyLevel_setTwice()
138 .concurrencyLevel(1) in testConcurrencyLevel_small()
145 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE); in testConcurrencyLevel_large()
400 .concurrencyLevel(1) in testRemovalNotification_clear()
458 .concurrencyLevel(20) in testRemovalNotification_clear_basher()
559 .concurrencyLevel(2) in testRemovalNotification_get_basher()
DCacheBuilderFactory.java151 Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize,
156 if (concurrencyLevel != null) {
157 builder.concurrencyLevel(concurrencyLevel);
DLocalLoadingCacheTest.java79 .concurrencyLevel(1) in testStats()
139 .concurrencyLevel(1); in testStatsNoops()
182 .concurrencyLevel(1) in testNoStats()
206 .concurrencyLevel(1) in testRecordStats()
293 .concurrencyLevel(1) in testAsMapRecency()
/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DOkHttpAsync.java43 private int concurrencyLevel; field in OkHttpAsync
47 concurrencyLevel = benchmark.concurrencyLevel; in prepare()
52 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel, in prepare()
53 benchmark.concurrencyLevel, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()))); in prepare()
92 return requestsInFlight.get() < (concurrencyLevel + targetBacklog); in acceptingJobs()
DNettyHttpClient.java59 private int concurrencyLevel; field in NettyHttpClient
64 this.concurrencyLevel = benchmark.concurrencyLevel; in prepare()
85 bootstrap.group(new NioEventLoopGroup(concurrencyLevel)) in prepare()
96 } else if (totalChannels < concurrencyLevel) { in enqueue()
117 return activeChannels < concurrencyLevel; in hasFreeChannels()
DSynchronousHttpClient.java32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel, in prepare()
DBenchmark.java57 int concurrencyLevel; field in Benchmark
149 client, modifiers, bodyByteCount, headerCount, concurrencyLevel); in toString()
/external/guava/guava/src/com/google/common/cache/
DCacheBuilder.java220 int concurrencyLevel = UNSET_INT; field in CacheBuilder
373 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
374 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", in concurrencyLevel()
375 this.concurrencyLevel); in concurrencyLevel()
376 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
377 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
382 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
838 if (concurrencyLevel != UNSET_INT) { in toString()
839 s.add("concurrencyLevel", concurrencyLevel); in toString()
DCacheBuilderSpec.java115 @VisibleForTesting Integer concurrencyLevel; field in CacheBuilderSpec
181 if (concurrencyLevel != null) { in toCacheBuilder()
182 builder.concurrencyLevel(concurrencyLevel); in toCacheBuilder()
246 concurrencyLevel, in hashCode()
267 && Objects.equal(concurrencyLevel, that.concurrencyLevel) in equals()
357 checkArgument(spec.concurrencyLevel == null, in parseInteger()
358 "concurrency level was already set to ", spec.concurrencyLevel); in parseInteger()
359 spec.concurrencyLevel = value; in parseInteger()
/external/guava/guava/src/com/google/common/collect/
DMapMaker.java117 int concurrencyLevel = UNSET_INT; field in MapMaker
239 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
240 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", in concurrencyLevel()
241 this.concurrencyLevel); in concurrencyLevel()
242 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
243 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
248 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
600 if (concurrencyLevel != UNSET_INT) { in toString()
601 s.add("concurrencyLevel", concurrencyLevel); in toString()
DGenericMapMaker.java85 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); in concurrencyLevel() argument
DComputingConcurrentHashMap.java384 concurrencyLevel, removalListener, this, computingFunction); in writeReplace()
394 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, in ComputingSerializationProxy() argument
397 expireAfterAccessNanos, maximumSize, concurrencyLevel, removalListener, delegate); in ComputingSerializationProxy()
/external/guava/guava-tests/test/com/google/common/collect/
DMapMakerInternalMapTest.java93 assertEquals(4, map.concurrencyLevel); in testDefaults()
138 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
140 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
179 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
181 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkInitialCapacity()
212 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) { in checkMaximumSize() argument
214 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
354 .concurrencyLevel(1) in testRemovalListener_collected()
380 .concurrencyLevel(1) in testRemovalListener_size()
492 makeMap(createMapMaker().concurrencyLevel(1).expireAfterAccess(99999, SECONDS)); in testSegmentGetAndContains()
[all …]
DComputingConcurrentHashMapTest.java109 makeComputingMap(maker.concurrencyLevel(1), computingFunction); in testRecordReadOnCompute()
164 MapMaker maker = createMapMaker().concurrencyLevel(1); in testComputePartiallyCollectedKey()
193 MapMaker maker = createMapMaker().concurrencyLevel(1); in testComputePartiallyCollectedValue()
/external/guava/guava-gwt/test-super/com/google/common/cache/super/com/google/common/cache/
DCacheBuilderTest.java74 builder.concurrencyLevel(0); in testConcurrencyLevel_zero()
80 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16); in testConcurrencyLevel_setTwice()
83 builder.concurrencyLevel(16); in testConcurrencyLevel_setTwice()
89 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE); in testConcurrencyLevel_large()
/external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/
DGenericMapMaker.java65 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); in concurrencyLevel() method in GenericMapMaker
DMapMaker.java205 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in MapMaker
206 if (concurrencyLevel < 1) { in concurrencyLevel()
/external/icu/android_icu4j/src/main/java/android/icu/impl/locale/
DLocaleObjectCache.java27 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { in LocaleObjectCache() argument
28 … _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel); in LocaleObjectCache()
/external/icu/icu4j/eclipse-build/plugins.template/com.ibm.icu.base/src/com/ibm/icu/impl/locale/
DLocaleObjectCache.java23 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { in LocaleObjectCache() argument
24 … _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel); in LocaleObjectCache()
/external/icu/icu4j/main/classes/core/src/com/ibm/icu/impl/locale/
DLocaleObjectCache.java23 public LocaleObjectCache(int initialCapacity, float loadFactor, int concurrencyLevel) { in LocaleObjectCache() argument
24 … _map = new ConcurrentHashMap<K, CacheEntry<K, V>>(initialCapacity, loadFactor, concurrencyLevel); in LocaleObjectCache()
/external/guava/guava-tests/benchmark/com/google/common/cache/
DChainBenchmark.java42 .concurrencyLevel(1), null); in setUp()

12