Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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());
        assertEquals(EMPTY_STATS, cache.stats());
    
        Object one = new Object();
        cache.getUnchecked(one);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  2. android/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);
          assertEquals(min(i + 1, MAX_SIZE), cache.size());
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 15K bytes
    - Viewed (0)
  3. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue Jul 08 18:32:10 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  4. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 25.1K bytes
    - Viewed (0)
  5. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 25K bytes
    - Viewed (0)
  6. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  8. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java

        FakeTicker ticker = new FakeTicker();
        IdentityLoader<Integer> loader = identityLoader();
        LoadingCache<Integer, Integer> cache =
            CacheBuilder.newBuilder()
                .concurrencyLevel(1)
                .expireAfterAccess(11, MILLISECONDS)
                .ticker(ticker)
                .build(loader);
        for (int i = 0; i < 10; i++) {
          cache.getUnchecked(i);
          ticker.advance(1, MILLISECONDS);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 18.7K 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top