Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 91 for ConcurrentHashMap (0.5 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top