Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for AtomicReferenceArray (0.09 sec)

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

    import java.util.Random;
    import java.util.Set;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.logging.LogRecord;
    import junit.framework.Test;
    import junit.framework.TestCase;
    import junit.framework.TestSuite;
    import org.jspecify.annotations.NullUnmarked;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 110.5K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        @Nullable E copyEntry(E original, E newNext) {
          return this.map.entryHelper.copy(self(), original, newNext);
        }
    
        AtomicReferenceArray<E> newEntryArray(int size) {
          return new AtomicReferenceArray<>(size);
        }
    
        void initTable(AtomicReferenceArray<E> newTable) {
          this.threshold = newTable.length() * 3 / 4; // 0.75
          this.table = newTable;
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Striped.java

       * AtomicReferenceArray of size 2^k. To map a user key into a stripe, we take a k-bit slice of the
       * user key's (smeared) hashCode(). The stripes are lazily initialized and are weakly referenced.
       */
      @VisibleForTesting
      static final class SmallLazyStriped<L> extends PowerOfTwoStriped<L> {
        final AtomicReferenceArray<@Nullable ArrayReference<? extends L>> locks;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

      private static <K> List<Object> doConcurrentGet(
          LoadingCache<K, ?> cache, K key, int nThreads, CountDownLatch gettersStartedSignal)
          throws InterruptedException {
    
        AtomicReferenceArray<Object> result = new AtomicReferenceArray<>(nThreads);
        CountDownLatch gettersComplete = new CountDownLatch(nThreads);
        for (int i = 0; i < nThreads; i++) {
          int index = i;
          Thread thread =
              new Thread(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 85.7K bytes
    - Viewed (0)
Back to top