Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for concurrencyLevel (0.27 seconds)

  1. guava/src/com/google/common/collect/MapMaker.java

       *
       * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
       * @throws IllegalStateException if a concurrency level was already set
       */
      @CanIgnoreReturnValue
      public MapMaker concurrencyLevel(int concurrencyLevel) {
        checkState(
            this.concurrencyLevel == UNSET_INT,
            "concurrency level was already set to %s",
            this.concurrencyLevel);
        checkArgument(concurrencyLevel > 0);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/cache/CacheBuilderSpec.java

        }
      }
    
      /** Parse concurrencyLevel */
      private static final class ConcurrencyLevelParser extends IntegerParser {
        @Override
        void parseInteger(CacheBuilderSpec spec, int value) {
          checkArgument(
              spec.concurrencyLevel == null,
              "concurrency level was already set to %s",
              spec.concurrencyLevel);
          spec.concurrencyLevel = value;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  3. guava/src/com/google/common/cache/CacheBuilderSpec.java

        }
      }
    
      /** Parse concurrencyLevel */
      private static final class ConcurrencyLevelParser extends IntegerParser {
        @Override
        void parseInteger(CacheBuilderSpec spec, int value) {
          checkArgument(
              spec.concurrencyLevel == null,
              "concurrency level was already set to %s",
              spec.concurrencyLevel);
          spec.concurrencyLevel = value;
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/MapMaker.java

       *
       * @throws IllegalArgumentException if {@code concurrencyLevel} is nonpositive
       * @throws IllegalStateException if a concurrency level was already set
       */
      @CanIgnoreReturnValue
      public MapMaker concurrencyLevel(int concurrencyLevel) {
        checkState(
            this.concurrencyLevel == UNSET_INT,
            "concurrency level was already set to %s",
            this.concurrencyLevel);
        checkArgument(concurrencyLevel > 0);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 12.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        checkConcurrencyLevel(7, 8);
        checkConcurrencyLevel(8, 8);
      }
    
      private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) {
        MapMakerInternalMap<Object, Object, ?, ?> map =
            makeMap(createMapMaker().concurrencyLevel(concurrencyLevel));
        assertThat(map.segments).hasLength(segmentCount);
      }
    
      public void testSetInitialCapacity() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 36K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        checkConcurrencyLevel(7, 8);
        checkConcurrencyLevel(8, 8);
      }
    
      private static void checkConcurrencyLevel(int concurrencyLevel, int segmentCount) {
        MapMakerInternalMap<Object, Object, ?, ?> map =
            makeMap(createMapMaker().concurrencyLevel(concurrencyLevel));
        assertThat(map.segments).hasLength(segmentCount);
      }
    
      public void testSetInitialCapacity() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 36K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/cache/CacheEvictionTest.java

        }
      }
    
      public void testEviction_maxSizeOneSegment() {
        IdentityLoader<Integer> loader = identityLoader();
        LoadingCache<Integer, Integer> cache =
            CacheBuilder.newBuilder().concurrencyLevel(1).maximumSize(MAX_SIZE).build(loader);
        for (int i = 0; i < 2 * MAX_SIZE; i++) {
          cache.getUnchecked(i);
          assertThat(cache.size()).isEqualTo(min(i + 1, MAX_SIZE));
        }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 15K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/cache/CacheBuilderSpecTest.java

      }
    
      public void testEqualsAndHashCode() {
        new EqualsTester()
            .addEqualityGroup(parse(""), parse(""))
            .addEqualityGroup(parse("concurrencyLevel=7"), parse("concurrencyLevel=7"))
            .addEqualityGroup(parse("concurrencyLevel=15"), parse("concurrencyLevel=15"))
            .addEqualityGroup(parse("initialCapacity=7"), parse("initialCapacity=7"))
            .addEqualityGroup(parse("initialCapacity=15"), parse("initialCapacity=15"))
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 20.8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        tester.testAllPublicInstanceMethods(makeCache(createCacheBuilder(), loader));
      }
    
      // stats tests
    
      public void testStats() {
        CacheBuilder<Object, Object> builder = createCacheBuilder().concurrencyLevel(1).maximumSize(2);
        LocalLoadingCache<Object, Object> cache = makeCache(builder, identityLoader());
        assertThat(cache.stats()).isEqualTo(EMPTY_STATS);
    
        Object one = new Object();
        cache.getUnchecked(one);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

        tester.testAllPublicInstanceMethods(makeCache(createCacheBuilder(), loader));
      }
    
      // stats tests
    
      public void testStats() {
        CacheBuilder<Object, Object> builder = createCacheBuilder().concurrencyLevel(1).maximumSize(2);
        LocalLoadingCache<Object, Object> cache = makeCache(builder, identityLoader());
        assertThat(cache.stats()).isEqualTo(EMPTY_STATS);
    
        Object one = new Object();
        cache.getUnchecked(one);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 18 18:06:14 GMT 2026
    - 13.1K bytes
    - Click Count (0)
Back to Top