Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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. 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)
  3. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

        private static final int MAX_BACKOFF_SHIFT = 3; // Maximum 8 seconds (2^3 * 1000ms)
    
        private final DirectoryLeaseManager leaseManager;
        private final ConcurrentHashMap<String, ChangeNotificationHandle> activeWatchers;
        private final ConcurrentHashMap<String, Integer> failureCounts;
    
        /**
         * Directory change types
         */
        public enum DirectoryChangeType {
            /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 13.7K 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. okhttp/src/jvmTest/kotlin/okhttp3/SocksProxy.kt

    import java.net.InetSocketAddress
    import java.net.ProtocolException
    import java.net.Proxy
    import java.net.ServerSocket
    import java.net.Socket
    import java.net.SocketException
    import java.util.concurrent.ConcurrentHashMap
    import java.util.concurrent.Executors
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.atomic.AtomicInteger
    import java.util.logging.Level
    import java.util.logging.Logger
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 7.6K bytes
    - Viewed (0)
Back to top