- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 68 for ConcurrentHashMap (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)