- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 91 for ConcurrentHashMap (0.5 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/org/codelibs/fess/chat/ChatSessionManager.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.chat; import java.time.LocalDateTime; import java.util.Iterator; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; import org.codelibs.core.timer.TimeoutManager; import org.codelibs.core.timer.TimeoutTask;
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 07 13:27:59 GMT 2026 - 13.7K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/deployer/DefaultArtifactDeployer.java
* under the License. */ package org.apache.maven.artifact.deployer; import javax.inject.Inject; import javax.inject.Named; import java.io.File; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import org.apache.maven.RepositoryUtils; import org.apache.maven.artifact.Artifact; import org.apache.maven.artifact.metadata.ArtifactMetadata; import org.apache.maven.artifact.repository.ArtifactRepository;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Jun 06 14:28:57 GMT 2025 - 6.4K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java
getContainsEntryWithIncomparableValueMethod()); } @Override protected Collection<Method> suppressForConcurrentHashMap() { /* * The entrySet() of ConcurrentHashMap, unlike that of other Map * implementations, supports add() under JDK8. This seems problematic, but I * didn't see that discussed in the review, which included many other
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 3.9K bytes - Click Count (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());Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 15.1K bytes - Click Count (0) -
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() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6K bytes - Click Count (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() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 6K bytes - Click Count (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;
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 16.2K bytes - Click Count (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
private volatile boolean shutdown = false; // Event statistics private final Map<EventType, AtomicLong> eventCounters = new ConcurrentHashMap<>(); private final Map<EventType, AtomicLong> eventTimings = new ConcurrentHashMap<>(); // Configuration private volatile boolean enableJsonLogging = true; private volatile boolean maskSensitiveData = true;Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 26.6K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
import java.util.Arrays; import java.util.Collection; import java.util.Collections; import java.util.List; import java.util.Map; import java.util.Set; import java.util.TreeSet; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import org.apache.maven.api.SessionData;
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Thu Jun 12 14:55:55 GMT 2025 - 21K bytes - Click Count (0) -
guava-testlib/test/com/google/common/collect/testing/OpenJdk6MapTests.java
getContainsEntryWithIncomparableValueMethod()); } @Override protected Collection<Method> suppressForConcurrentHashMap() { /* * The entrySet() of ConcurrentHashMap, unlike that of other Map * implementations, supports add() under JDK8. This seems problematic, but I * didn't see that discussed in the review, which included many other
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 4.1K bytes - Click Count (0)