| /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/ |
| OkHttpAsync.java | 42 private int concurrencyLevel;
46 concurrencyLevel = benchmark.concurrencyLevel;
51 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel,
52 benchmark.concurrencyLevel, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>())));
92 return requestsInFlight.get() < (concurrencyLevel + targetBacklog);
|
| SynchronousHttpClient.java | 32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel,
|
| NettyHttpClient.java | 60 private int concurrencyLevel;
65 this.concurrencyLevel = benchmark.concurrencyLevel;
86 bootstrap.group(new NioEventLoopGroup(concurrencyLevel))
97 } else if (totalChannels < concurrencyLevel) {
118 return activeChannels < concurrencyLevel;
|
| Benchmark.java | 58 int concurrencyLevel;
149 return String.format("%s %s\nbodyByteCount=%s headerCount=%s concurrencyLevel=%s",
150 client, modifiers, bodyByteCount, headerCount, concurrencyLevel);
|
| /external/guava/guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ |
| GenericMapMaker.java | 60 * See {@link MapMaker#concurrencyLevel}.
62 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel);
|
| MapMaker.java | 220 public MapMaker concurrencyLevel(int concurrencyLevel) {
221 if (concurrencyLevel < 1) {
224 // GWT technically only supports concurrencyLevel == 1, but we silently
|
| /external/guava/guava/src/com/google/common/cache/ |
| CacheBuilder.java | 204 int concurrencyLevel = UNSET_INT;
314 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
317 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) {
318 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s",
319 this.concurrencyLevel);
320 checkArgument(concurrencyLevel > 0);
321 this.concurrencyLevel = concurrencyLevel;
326 return (concurrencyLevel == UNSET_INT) ? DEFAULT_CONCURRENCY_LEVEL : concurrencyLevel
[all...] |
| LocalCache.java | 173 final int concurrencyLevel;
234 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
265 // && (concurrencyLevel > maxWeight || segmentCount > concurrencyLevel)
268 while (segmentCount < concurrencyLevel
[all...] |
| /external/guava/guava/src/com/google/common/collect/ |
| MapMaker.java | 63 * .concurrencyLevel(4)
125 int concurrencyLevel = UNSET_INT;
267 * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
271 public MapMaker concurrencyLevel(int concurrencyLevel) {
272 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s",
273 this.concurrencyLevel);
274 checkArgument(concurrencyLevel > 0);
275 this.concurrencyLevel = concurrencyLevel;
[all...] |
| GenericMapMaker.java | 86 * See {@link MapMaker#concurrencyLevel}.
88 public abstract GenericMapMaker<K0, V0> concurrencyLevel(int concurrencyLevel);
|
| ComputingConcurrentHashMap.java | 381 concurrencyLevel, removalListener, this, computingFunction);
391 int concurrencyLevel, RemovalListener<? super K, ? super V> removalListener,
394 expireAfterAccessNanos, maximumSize, concurrencyLevel, removalListener, delegate);
|
| MapMakerInternalMap.java | 154 final int concurrencyLevel;
197 concurrencyLevel = Math.min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
224 // && (concurrencyLevel > maximumSize || segmentCount > concurrencyLevel)
227 while (segmentCount < concurrencyLevel
[all...] |
| /external/guava/guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/ |
| CacheBuilder.java | 51 private int concurrencyLevel = -1;
73 public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) {
74 checkState(this.concurrencyLevel == UNSET_INT, "concurrency level was already set to %s",
75 this.concurrencyLevel);
76 checkArgument(concurrencyLevel > 0);
77 // GWT technically only supports concurrencyLevel == 1, but we silently
79 this.concurrencyLevel = concurrencyLevel;
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| CacheEvictionTest.java | 67 .concurrencyLevel(1)
82 .concurrencyLevel(1)
151 .concurrencyLevel(1)
167 .concurrencyLevel(1)
199 .concurrencyLevel(1)
242 .concurrencyLevel(1)
265 .concurrencyLevel(1)
|
| CacheBuilderFactory.java | 150 Integer concurrencyLevel, Integer initialCapacity, Integer maximumSize,
155 if (concurrencyLevel != null) {
156 builder.concurrencyLevel(concurrencyLevel);
|
| LocalCacheTest.java | 139 assertEquals(4, map.concurrencyLevel);
204 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) {
206 makeLocalCache(createCacheBuilder().concurrencyLevel(concurrencyLevel));
245 int concurrencyLevel, int initialCapacity, int segmentSize) {
247 createCacheBuilder().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity));
254 // vary maximumSize wrt concurrencyLevel
278 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, long maxSize) {
280 .concurrencyLevel(concurrencyLevel
[all...] |
| CacheBuilderTest.java | 122 builder.concurrencyLevel(0);
128 CacheBuilder<Object, Object> builder = new CacheBuilder<Object, Object>().concurrencyLevel(16);
131 builder.concurrencyLevel(16);
139 .concurrencyLevel(1)
146 CacheBuilder.newBuilder().concurrencyLevel(Integer.MAX_VALUE);
407 .concurrencyLevel(1)
465 .concurrencyLevel(20)
565 .concurrencyLevel(2)
|
| LocalLoadingCacheTest.java | 84 .concurrencyLevel(1)
144 .concurrencyLevel(1);
183 .concurrencyLevel(1)
266 .concurrencyLevel(1)
|
| CacheExpirationTest.java | 254 .concurrencyLevel(1)
306 .concurrencyLevel(1)
353 .concurrencyLevel(1)
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| MapMakerInternalMapTest.java | 93 assertEquals(4, map.concurrencyLevel);
157 private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) {
159 makeMap(createMapMaker().concurrencyLevel(concurrencyLevel));
198 int concurrencyLevel, int initialCapacity, int segmentSize) {
200 createMapMaker().concurrencyLevel(concurrencyLevel).initialCapacity(initialCapacity));
207 // vary maximumSize wrt concurrencyLevel
231 private static void checkMaximumSize(int concurrencyLevel, int initialCapacity, int maxSize) {
233 .concurrencyLevel(concurrencyLevel
[all...] |
| MapMakerTest.java | 56 .concurrencyLevel(1)
113 .concurrencyLevel(20)
|
| ComputingConcurrentHashMapTest.java | 113 makeComputingMap(maker.concurrencyLevel(1), computingFunction);
168 MapMaker maker = createMapMaker().concurrencyLevel(1);
197 MapMaker maker = createMapMaker().concurrencyLevel(1);
|
| ConcurrentHashMultisetTest.java | 532 .concurrencyLevel(1)
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ConcurrentHashMap.java | 84 * expected {@code concurrencyLevel} as an additional hint for
310 * concurrencyLevel. We accept a loadFactor constructor argument,
688 * updating threads ({@code concurrencyLevel}).
695 * @param concurrencyLevel the estimated number of concurrently
699 * negative or the load factor or concurrencyLevel are
703 float loadFactor, int concurrencyLevel) {
704 if (!(loadFactor > 0.0f) || initialCapacity < 0 || concurrencyLevel <= 0)
706 if (initialCapacity < concurrencyLevel) // Use at least as many bins
707 initialCapacity = concurrencyLevel; // as estimated threads
[all...] |
| /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/sonatype/sisu/sisu-guice/2.1.7/ |
| sisu-guice-2.1.7-noaop.jar | |
