Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 28 for concurrencyLevel (0.07 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheBuilderFactory.java

          @Nullable Strength keyStrength,
          @Nullable Strength valueStrength) {
    
        CacheBuilder<Object, Object> builder = CacheBuilder.newBuilder();
        if (concurrencyLevel != null) {
          builder.concurrencyLevel(concurrencyLevel);
        }
        if (initialCapacity != null) {
          builder.initialCapacity(initialCapacity);
        }
        if (maximumSize != null) {
          builder.maximumSize(maximumSize);
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/cache/CacheBuilder.java

       */
      @CanIgnoreReturnValue
      public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) {
        checkState(
            this.concurrencyLevel == UNSET_INT,
            "concurrency level was already set to %s",
            this.concurrencyLevel);
        checkArgument(concurrencyLevel > 0);
        this.concurrencyLevel = concurrencyLevel;
        return this;
      }
    
      int getConcurrencyLevel() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.9K bytes
    - Viewed (0)
  3. 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);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/Interners.java

        }
    
        /**
         * Sets the concurrency level that will be used by the to-be-built {@link Interner}.
         *
         * @see MapMaker#concurrencyLevel(int)
         */
        @CanIgnoreReturnValue
        public InternerBuilder concurrencyLevel(int concurrencyLevel) {
          this.mapMaker.concurrencyLevel(concurrencyLevel);
          return this;
        }
    
        public <E> Interner<E> build() {
          if (!strong) {
            mapMaker.weakKeys();
          }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/cache/CacheBuilderTest.java

        assertThrows(IllegalArgumentException.class, () -> builder.concurrencyLevel(0));
      }
    
      public void testConcurrencyLevel_setTwice() {
        CacheBuilder<Object, Object> builder = CacheBuilder.newBuilder().concurrencyLevel(16);
        assertThrows(IllegalStateException.class, () -> builder.concurrencyLevel(16));
      }
    
      @GwtIncompatible // CacheTesting
      public void testConcurrencyLevel_small() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/CacheBuilder.java

       */
      @CanIgnoreReturnValue
      public CacheBuilder<K, V> concurrencyLevel(int concurrencyLevel) {
        checkState(
            this.concurrencyLevel == UNSET_INT,
            "concurrency level was already set to %s",
            this.concurrencyLevel);
        checkArgument(concurrencyLevel > 0);
        this.concurrencyLevel = concurrencyLevel;
        return this;
      }
    
      int getConcurrencyLevel() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  7. guava-tests/benchmark/com/google/common/cache/SegmentBenchmark.java

      int capacity;
    
      private Segment<Object, Object> segment;
    
      @BeforeExperiment
      void setUp() {
        LocalCache<Object, Object> cache =
            new LocalCache<>(
                CacheBuilder.newBuilder().concurrencyLevel(1).initialCapacity(capacity), null);
        checkState(cache.segments.length == 1);
        segment = cache.segments[0];
        checkState(segment.table.length() == capacity);
        for (int i = 0; i < segment.threshold; i++) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. android/guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java

      @SuppressWarnings("GuardedBy")
      @BeforeExperiment
      void setUp() {
        LocalCache<Object, Object> cache =
            new LocalCache<>(CacheBuilder.newBuilder().concurrencyLevel(1), null);
        segment = cache.segments[0];
        chain = null;
        for (int i = 0; i < length; i++) {
          Object key = new Object();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        concurrencyLevel = min(builder.getConcurrencyLevel(), MAX_SEGMENTS);
    
        keyEquivalence = builder.getKeyEquivalence();
        this.entryHelper = entryHelper;
    
        int initialCapacity = min(builder.getInitialCapacity(), MAXIMUM_CAPACITY);
    
        // Find power-of-two sizes best matching arguments. Constraints:
        // (segmentCount > concurrencyLevel)
        int segmentShift = 0;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 89.9K bytes
    - Viewed (0)
  10. android/guava-tests/benchmark/com/google/common/cache/LoadingCacheSingleThreadBenchmark.java

        // power of (1/concentration) and floor()ed
        max = Ints.checkedCast((long) Math.pow(distinctKeys, concentration));
    
        cache =
            CacheBuilder.newBuilder()
                .concurrencyLevel(segments)
                .maximumSize(maximumSize)
                .build(
                    new CacheLoader<Integer, Integer>() {
                      @Override
                      public Integer load(Integer from) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top