Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 68 for ConcurrentHashMap (0.52 sec)

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddTester.java

       * what to do with <a
       * href="https://github.com/openjdk/jdk/blob/c25c4896ad9ef031e3cddec493aef66ff87c48a7/src/java.base/share/classes/java/util/concurrent/ConcurrentHashMap.java#L4830">{@code
       * ConcurrentHashMap} support for {@code entrySet().add()}</a>.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
      public static Method getAddUnsupportedNotPresentMethod() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/collect/testing/testers/CollectionAddTester.java

       * what to do with <a
       * href="https://github.com/openjdk/jdk/blob/c25c4896ad9ef031e3cddec493aef66ff87c48a7/src/java.base/share/classes/java/util/concurrent/ConcurrentHashMap.java#L4830">{@code
       * ConcurrentHashMap} support for {@code entrySet().add()}</a>.
       */
      @J2ktIncompatible
      @GwtIncompatible // reflection
      public static Method getAddUnsupportedNotPresentMethod() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

        private final Map<String, ConnectionMetrics> connectionMetrics = new ConcurrentHashMap<>();
    
        // Proactive health monitoring
        private volatile boolean proactiveHealthCheckEnabled = true;
        private final long proactiveCheckInterval = DEFAULT_PROACTIVE_CHECK_INTERVAL;
    
        // Connection failure tracking
        private final Map<String, Long> lastFailureTimes = new ConcurrentHashMap<>();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  4. src/main/java/jcifs/util/ResourceManager.java

    import java.lang.ref.Reference;
    import java.lang.ref.ReferenceQueue;
    import java.lang.ref.WeakReference;
    import java.util.Collections;
    import java.util.Map;
    import java.util.Set;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.Executors;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/AuthenticationRateLimiter.java

        private final Duration lockoutDuration;
        private final Duration cleanupInterval;
    
        // Tracking maps
        private final Map<String, AccountAttempts> accountAttempts = new ConcurrentHashMap<>();
        private final Map<String, IpAttempts> ipAttempts = new ConcurrentHashMap<>();
        private final AtomicInteger globalAttemptsInCurrentWindow = new AtomicInteger(0);
        private final AtomicLong currentWindowStart = new AtomicLong(System.currentTimeMillis());
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/util/SecureKeyManager.java

        private static final Logger log = LoggerFactory.getLogger(SecureKeyManager.class);
    
        private final Map<String, SecretKey> sessionKeys = new ConcurrentHashMap<>();
        private final Map<String, byte[]> rawKeys = new ConcurrentHashMap<>();
        private final SecureRandom secureRandom = new SecureRandom();
        private KeyStore keyStore;
        private char[] keyStorePassword;
        private volatile boolean closed = false;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 21.5K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java

    import com.google.common.base.Function;
    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;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

     * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     */
    package jcifs.internal.smb2.lease;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    
    /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/filter/EncodingFilter.java

    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ConcurrentHashMap;
    
    import org.apache.commons.codec.DecoderException;
    import org.apache.commons.codec.net.URLCodec;
    import org.codelibs.core.lang.StringUtil;
    import org.lastaflute.web.servlet.filter.LastaPrepareFilter;
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/TestsForMapsInJavaUtil.java

                  @Override
                  protected Map<String, String> create(Entry<String, String>[] entries) {
                    return populate(new ConcurrentHashMap<String, String>(), entries);
                  }
                })
            .named("ConcurrentHashMap")
            .withFeatures(
                MapFeature.GENERAL_PURPOSE,
                CollectionFeature.SUPPORTS_ITERATOR_REMOVE,
                CollectionFeature.SERIALIZABLE,
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 16:28:01 UTC 2025
    - 17.2K bytes
    - Viewed (0)
Back to top