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