Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for ConcurrentMap (0.06 sec)

  1. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 21.8K bytes
    - Viewed (0)
  2. 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 Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/MapMaker.java

    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A builder of {@link ConcurrentMap} instances that can have keys or values automatically wrapped
     * in {@linkplain WeakReference weak} references.
     *
     * <p>Usage example:
     *
     * {@snippet :
     * ConcurrentMap<Request, Stopwatch> timers = new MapMaker()
     *     .concurrencyLevel(4)
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  4. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Aug 10 19:54:19 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/beans/factory/BeanDescFactory.java

    import static org.codelibs.core.collection.CollectionsUtil.putIfAbsent;
    import static org.codelibs.core.misc.AssertionUtil.assertArgumentNotNull;
    
    import java.util.concurrent.ConcurrentMap;
    
    import org.codelibs.core.beans.BeanDesc;
    import org.codelibs.core.beans.impl.BeanDescImpl;
    import org.codelibs.core.misc.DisposableUtil;
    
    /**
     * This class generates {@link BeanDesc}.
     * <p>
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Thu Jul 31 08:16:49 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

    import com.google.common.primitives.Ints;
    import java.util.List;
    import java.util.Random;
    import java.util.concurrent.Callable;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ConcurrentSkipListMap;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/PreauthIntegrityService.java

    import java.security.MessageDigest;
    import java.security.NoSuchAlgorithmException;
    import java.security.SecureRandom;
    import java.util.Arrays;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.CIFSException;
    import jcifs.internal.smb2.nego.PreauthIntegrityNegotiateContext;
    
    /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

     */
    package jcifs.internal.smb2.multichannel;
    
    import java.io.IOException;
    import java.util.List;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.TimeUnit;
    
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import jcifs.SmbTransport;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Striped.java

       * where the key domain is [0..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 LargeLazyStriped<L> extends PowerOfTwoStriped<L> {
        final ConcurrentMap<Integer, L> locks;
        final Supplier<L> supplier;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/MultiChannelManager.java

    import java.net.InetAddress;
    import java.net.NetworkInterface;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.CopyOnWriteArrayList;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 20.5K bytes
    - Viewed (0)
Back to top