Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for ConcurrentMap (0.07 sec)

  1. impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java

         * ({@link PluginDescriptor#getPluginLookupKey()}). Plugin contexts itself are mappings of {@link String} keys to
         * {@link Object} values.
         */
        private final ConcurrentMap<String, ConcurrentMap<String, ConcurrentMap<String, Object>>>
                pluginContextsByProjectAndPluginKey = new ConcurrentHashMap<>();
    
        public void setProjects(List<MavenProject> projects) {
            if (!projects.isEmpty()) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jan 24 17:29:44 UTC 2025
    - 16.7K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/cache/super/com/google/common/cache/LocalCache.java

      // currently only package visible.
      abstract class AbstractCacheSet<T> extends AbstractSet<T> {
        final ConcurrentMap<?, ?> map;
    
        AbstractCacheSet(ConcurrentMap<?, ?> map) {
          this.map = map;
        }
    
        @Override
        public int size() {
          return map.size();
        }
    
        @Override
        public boolean isEmpty() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentNavigableMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.Executor;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java

    import com.google.common.collect.ImmutableSet;
    import com.google.common.testing.NullPointerTester;
    import java.lang.Thread.UncaughtExceptionHandler;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicReference;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * @author Charles Fry
     */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/collect/BenchmarkHelpers.java

            ConcurrentMap<K, V> newMap = new MapMaker().weakValues().makeMap();
            checkState(newMap instanceof MapMakerInternalMap);
            newMap.putAll(map);
            return newMap;
          }
        },
        MapMakerWeakKeysStrongValues {
          @Override
          public <K extends Comparable<K>, V> Map<K, V> create(Map<K, V> map) {
            ConcurrentMap<K, V> newMap = new MapMaker().weakKeys().makeMap();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  6. impl/maven-core/src/main/java/org/apache/maven/plugin/version/internal/DefaultPluginVersionResolver.java

                    }
                }
            }
            return null;
        }
    
        @SuppressWarnings("unchecked")
        private ConcurrentMap<Key, PluginVersionResult> getCache(PluginVersionRequest request) {
            SessionData data = request.getRepositorySession().getData();
            return (ConcurrentMap<Key, PluginVersionResult>)
                    data.computeIfAbsent(CACHE_KEY, () -> new ConcurrentHashMap<>(256));
        }
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jan 29 08:17:07 UTC 2025
    - 17.6K bytes
    - Viewed (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

            private final int maxCountLimit;
            private final AtomicInteger totalCount;
            private final ConcurrentMap<BuilderProblem.Severity, LongAdder> counters;
            private final ConcurrentMap<BuilderProblem.Severity, List<P>> problems;
            private final Predicate<? super P> filter;
    
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

          }
        };
      }
    
      private static final String KEY = "puppies";
    
      ConcurrentMap<String, AtomicInteger> backingMap;
      ConcurrentHashMultiset<String> multiset;
    
      @SuppressWarnings("unchecked")
      @Override
      protected void setUp() {
        backingMap = mock(ConcurrentMap.class);
        when(backingMap.isEmpty()).thenReturn(true);
    
        multiset = ConcurrentHashMultiset.create(backingMap);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 16.3K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ConcurrentHashMultiset.java

       * @since 20.0
       */
      public static <E> ConcurrentHashMultiset<E> create(ConcurrentMap<E, AtomicInteger> countMap) {
        checkArgument(countMap.isEmpty(), "the backing map (%s) must be empty", countMap);
        return new ConcurrentHashMultiset<>(countMap);
      }
    
      private ConcurrentHashMultiset(ConcurrentMap<E, AtomicInteger> countMap) {
        this.countMap = countMap;
      }
    
      // Query Operations
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 22:42:14 UTC 2025
    - 22.3K bytes
    - Viewed (0)
  10. android/guava-testlib/test/com/google/common/testing/FreshValueGeneratorTest.java

        assertFreshInstance(new TypeToken<NavigableMap<?, ?>>() {});
      }
    
      public void testConcurrentMap() {
        assertFreshInstance(new TypeToken<ConcurrentMap<String, ?>>() {});
        assertCanGenerateOnly(
            new TypeToken<ConcurrentMap<EmptyEnum, String>>() {}, Maps.newConcurrentMap());
      }
    
      public void testMultimap() {
        assertFreshInstance(new TypeToken<Multimap<String, ?>>() {});
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 17.4K bytes
    - Viewed (0)
Back to top