Home
last modified time | relevance | path

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

/external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
DOkHttpAsync.java42 private int concurrencyLevel; field in OkHttpAsync
46 concurrencyLevel = benchmark.concurrencyLevel; in prepare()
51 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel, in prepare()
52 benchmark.concurrencyLevel, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()))); in prepare()
92 return requestsInFlight.get() < (concurrencyLevel + targetBacklog); in acceptingJobs()
DNettyHttpClient.java60 private int concurrencyLevel; field in NettyHttpClient
65 this.concurrencyLevel = benchmark.concurrencyLevel; in prepare()
86 bootstrap.group(new NioEventLoopGroup(concurrencyLevel)) in prepare()
97 } else if (totalChannels < concurrencyLevel) { in enqueue()
118 return activeChannels < concurrencyLevel; in hasFreeChannels()
DSynchronousHttpClient.java32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel, in prepare()
DBenchmark.java58 int concurrencyLevel; field in Benchmark
150 client, modifiers, bodyByteCount, headerCount, concurrencyLevel); in toString()
/external/guava/guava/src/com/google/common/cache/
DCacheBuilder.java204 int concurrencyLevel = UNSET_INT; field in CacheBuilder
317 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() argument
318 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", in concurrencyLevel()
319 this.concurrencyLevel); in concurrencyLevel()
320 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
321 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
326 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
788 if (concurrencyLevel != UNSET_INT) { in toString()
789 s.add("concurrencyLevel", concurrencyLevel); in toString()
DLocalCache.java173 final int concurrencyLevel; field in LocalCache
234 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS); in LocalCache()
268 while (segmentCount < concurrencyLevel in LocalCache()
4595 final int concurrencyLevel;
4612 cache.concurrencyLevel,
4622 Weigher<K, V> weigher, int concurrencyLevel,
4633 this.concurrencyLevel = concurrencyLevel;
4646 .concurrencyLevel(concurrencyLevel);
/external/guava/guava/src/com/google/common/collect/
DMapMaker.java125 int concurrencyLevel = UNSET_INT; field in MapMaker
271 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in MapMaker
272 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", in concurrencyLevel()
273 this.concurrencyLevel); in concurrencyLevel()
274 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
275 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
280 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel; in getConcurrencyLevel()
684 if (concurrencyLevel != UNSET_INT) { in toString()
685 s.add("concurrencyLevel", concurrencyLevel); in toString()
DGenericMapMaker.java88 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); in concurrencyLevel() method in GenericMapMaker
DComputingConcurrentHashMap.java381 concurrencyLevel, removalListener, this, computingFunction); in writeReplace()
391 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener, in ComputingSerializationProxy() argument
394 expireAfterAccessNanos, maximumSize, concurrencyLevel, removalListener, delegate); in ComputingSerializationProxy()
DMapMakerInternalMap.java154 final int concurrencyLevel; field in MapMakerInternalMap
197 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS); in MapMakerInternalMap()
227 while (segmentCount < concurrencyLevel in MapMakerInternalMap()
3940 concurrencyLevel, removalListener, this);
3958 final int concurrencyLevel;
3966 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener,
3975 this.concurrencyLevel = concurrencyLevel;
4003 .concurrencyLevel(concurrencyLevel);
4040 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener,
4043 expireAfterAccessNanos, maximumSize, concurrencyLevel, removalListener, delegate);
/external/guava/guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/
DCacheBuilder.java51 private int concurrencyLevel = -1; field in CacheBuilder
73 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in CacheBuilder
74 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s", in concurrencyLevel()
75 this.concurrencyLevel); in concurrencyLevel()
76 checkArgument(concurrencyLevel > 0); in concurrencyLevel()
79 this.concurrencyLevel = concurrencyLevel; in concurrencyLevel()
/external/guava/guava-tests/test/com/google/common/cache/
DCacheEvictionTest.java67 .concurrencyLevel(1) in testEviction_maxSizeOneSegment()
82 .concurrencyLevel(1) in testEviction_maxWeightOneSegment()
151 .concurrencyLevel(1) in testUpdateRecency_onInvalidate()
167 .concurrencyLevel(1) in testEviction_lru()
199 .concurrencyLevel(1) in testEviction_weightedLru()
242 .concurrencyLevel(1) in testEviction_overweight()
265 .concurrencyLevel(1) in testEviction_invalidateAll()
DLocalCacheTest.java139 assertEquals(4, map.concurrencyLevel); in testDefaults()
204 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
206 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
245 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
247 createCacheBuilder().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkInitialCapacity()
278 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) { in checkMaximumSize() argument
280 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
290 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
418 makeLocalCache(builder.concurrencyLevel(1)); in testRecordReadOnCompute()
472 CacheBuilder<Object, Object> builder = createCacheBuilder().concurrencyLevel(1); in testComputePartiallyCollectedKey()
[all …]
DCacheBuilderTest.java122 builder.concurrencyLevel(0); in testConcurrencyLevel_zero()
128 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16); in testConcurrencyLevel_setTwice()
131 builder.concurrencyLevel(16); in testConcurrencyLevel_setTwice()
139 .concurrencyLevel(1) in testConcurrencyLevel_small()
146 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE); in testConcurrencyLevel_large()
407 .concurrencyLevel(1) in testRemovalNotification_clear()
465 .concurrencyLevel(20) in testRemovalNotification_clear_basher()
565 .concurrencyLevel(2) in testRemovalNotification_get_basher()
DCacheBuilderFactory.java150 Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize,
155 if (concurrencyLevel != null) {
156 builder.concurrencyLevel(concurrencyLevel);
DLocalLoadingCacheTest.java84 .concurrencyLevel(1) in testStats()
144 .concurrencyLevel(1); in testStatsNoops()
183 .concurrencyLevel(1) in testDisableStats()
266 .concurrencyLevel(1) in testAsMapRecency()
DCacheExpirationTest.java254 .concurrencyLevel(1) in testExpirationOrder_access()
306 .concurrencyLevel(1) in testExpirationOrder_write()
353 .concurrencyLevel(1) in testExpirationOrder_writeAccess()
DCacheLoadingTest.java1661 .concurrencyLevel(1) in testReloadAfterSimulatedValueReclamation()
1685 .concurrencyLevel(1) in testReloadAfterSimulatedKeyReclamation()
/external/guava/guava-tests/test/com/google/common/collect/
DMapMakerInternalMapTest.java93 assertEquals(4, map.concurrencyLevel); in testDefaults()
157 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) { in checkConcurrencyLevel() argument
159 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel)); in checkConcurrencyLevel()
198 int concurrencyLevel, int initialCapacity, int segmentSize) { in checkInitialCapacity() argument
200 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity)); in checkInitialCapacity()
231 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) { in checkMaximumSize() argument
233 .concurrencyLevel(concurrencyLevel) in checkMaximumSize()
380 .concurrencyLevel(1) in testRemovalListener_collected()
406 .concurrencyLevel(1) in testRemovalListener_size()
518 makeMap(createMapMaker().concurrencyLevel(1).expireAfterAccess(99999, SECONDS)); in testSegmentGetAndContains()
[all …]
DMapMakerTest.java56 .concurrencyLevel(1) in testRemovalNotification_clear()
113 .concurrencyLevel(20) in testRemovalNotification_clear_basher()
DComputingConcurrentHashMapTest.java113 makeComputingMap(maker.concurrencyLevel(1), computingFunction); in testRecordReadOnCompute()
168 MapMaker maker = createMapMaker().concurrencyLevel(1); in testComputePartiallyCollectedKey()
197 MapMaker maker = createMapMaker().concurrencyLevel(1); in testComputePartiallyCollectedValue()
DConcurrentHashMultisetTest.java532 .concurrencyLevel(1) in testWithMapMakerEvictionListener()
/external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/
DGenericMapMaker.java62 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel); in concurrencyLevel() argument
DMapMaker.java220 public MapMaker concurrencyLevel(int concurrencyLevel) { in concurrencyLevel() method in MapMaker
221 if (concurrencyLevel < 1) { in concurrencyLevel()