Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for bCleanup (0.16 sec)

  1. guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertSame(valueThree, newFirst.getValue());
        assertEquals(hashThree, newFirst.getHash());
        assertNull(newFirst.getNext());
      }
    
      @SuppressWarnings("GuardedBy")
      public void testExpand_cleanup() {
        MapMakerInternalMap<Object, Object, ?, ?> map =
            makeMap(createMapMaker().concurrencyLevel(1).initialCapacity(1));
        Segment<Object, Object, ?, ?> segment = map.segments[0];
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 35.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertSame(valueThree, newFirst.getValue());
        assertEquals(hashThree, newFirst.getHash());
        assertNull(newFirst.getNext());
      }
    
      @SuppressWarnings("GuardedBy")
      public void testExpand_cleanup() {
        MapMakerInternalMap<Object, Object, ?, ?> map =
            makeMap(createMapMaker().concurrencyLevel(1).initialCapacity(1));
        Segment<Object, Object, ?, ?> segment = map.segments[0];
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 35.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/cache/LocalCache.java

          return false;
        }
    
        /**
         * Performs routine cleanup following a read. Normally cleanup happens during writes. If cleanup
         * is not observed after a sufficient number of reads, try cleaning up from the read thread.
         */
        void postReadCleanup() {
          if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
            cleanUp();
          }
        }
    
        /**
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 150.3K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          // structure for them.  Also, some implementations rely on this running prior to listeners
          // so that the cleanup work is visible to listeners.
          // afterDone() should be generally fast and only used for cleanup work... but in theory can
          // also be recursive and create StackOverflowErrors
          future.afterDone();
          // push the current set of listeners onto next
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/LocalCacheTest.java

        assertEquals(liveCount, originalMap.size());
        // can't compare map contents until cleanup occurs
    
        for (int i = 1; i <= originalCount * 2; i *= 2) {
          if (i > 1) {
            segment.expand();
          }
          assertEquals(i, segment.table.length());
          assertEquals(liveCount, countLiveEntries(map, 0));
          // expansion cleanup is sloppy, with a goal of avoiding unnecessary copies
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 112.3K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/cache/LocalCacheTest.java

        assertEquals(liveCount, originalMap.size());
        // can't compare map contents until cleanup occurs
    
        for (int i = 1; i <= originalCount * 2; i *= 2) {
          if (i > 1) {
            segment.expand();
          }
          assertEquals(i, segment.table.length());
          assertEquals(liveCount, countLiveEntries(map, 0));
          // expansion cleanup is sloppy, with a goal of avoiding unnecessary copies
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Mar 14 23:06:48 GMT 2024
    - 110.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

         * hold a reference to the executor and thus to the combiner. What we really care about is that
         * the futures are released once the combiner is done running. But we happen to provide this
         * earlier cleanup at the moment, so we're testing it.
         */
        GcFinalization.awaitClear(future1Ref);
        GcFinalization.awaitClear(future2Ref);
      }
    
      @AndroidIncompatible
      @J2ktIncompatible
      @GwtIncompatible
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

            tryDrainReferenceQueues();
            return null;
          }
    
          return value;
        }
    
        /**
         * Performs routine cleanup following a read. Normally cleanup happens during writes, or from
         * the cleanupExecutor. If cleanup is not observed after a sufficient number of reads, try
         * cleaning up from the read thread.
         */
        void postReadCleanup() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 91.9K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/cache/CacheTesting.java

      static void checkValidState(LocalCache<?, ?> cchm) {
        for (Segment<?, ?> segment : cchm.segments) {
          segment.cleanUp();
          assertFalse(segment.isLocked());
          Map<?, ?> table = segmentTable(segment);
          // cleanup and then check count after we have a strong reference to all entries
          segment.cleanUp();
          // under high memory pressure keys/values may be nulled out but not yet enqueued
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 16.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

         * hold a reference to the executor and thus to the combiner. What we really care about is that
         * the futures are released once the combiner is done running. But we happen to provide this
         * earlier cleanup at the moment, so we're testing it.
         */
        GcFinalization.awaitClear(future1Ref);
        GcFinalization.awaitClear(future2Ref);
      }
    
      @AndroidIncompatible
      @J2ktIncompatible
      @GwtIncompatible
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 144.5K bytes
    - Viewed (0)
Back to top