Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 881 - 890 of 1,216 for Concurrent (0.05 seconds)

  1. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueServiceTest.java

    import static org.codelibs.opensearch.runner.OpenSearchRunner.newConfigs;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.UUID;
    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.atomic.AtomicInteger;
    
    import org.codelibs.fess.crawler.client.FesenClient;
    import org.codelibs.fess.crawler.entity.OpenSearchUrlQueue;
    import org.codelibs.opensearch.runner.OpenSearchRunner;
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Wed Jan 14 23:48:16 GMT 2026
    - 14.5K bytes
    - Click Count (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

     * limitations under the License.
     */
    package mockwebserver3.internal
    
    import java.io.Closeable
    import java.io.InterruptedIOException
    import java.net.InetAddress
    import java.net.Socket
    import java.util.concurrent.CountDownLatch
    import javax.net.ssl.SSLSocket
    import okhttp3.Handshake
    import okhttp3.Handshake.Companion.handshake
    import okhttp3.internal.connection.BufferedSocket
    import okhttp3.internal.platform.Platform
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/core/collection/LruHashMap.java

     * Map<K, V> syncMap = Collections.synchronizedMap(new LruHashMap<>(100));
     * </pre>
     * <p>
     * Alternatively, for high-concurrency scenarios, consider implementing a custom
     * LRU cache using {@link java.util.concurrent.ConcurrentHashMap} with an eviction strategy.
     * </p>
     *
     * @author koichik
     * @param <K> the key type
     * @param <V> the value type
     */
    public class LruHashMap<K, V> extends LinkedHashMap<K, V> {
    
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Sat Nov 22 11:21:59 GMT 2025
    - 3K bytes
    - Click Count (0)
  4. guava/src/com/google/common/collect/SingletonImmutableBiMap.java

    import com.google.common.annotations.GwtCompatible;
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.annotations.J2ktIncompatible;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.RetainedWith;
    import java.util.function.BiConsumer;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Implementation of {@link ImmutableMap} with exactly one entry.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  5. guava-testlib/src/com/google/common/collect/testing/TestsForSetsInJavaUtil.java

    import java.util.Iterator;
    import java.util.LinkedHashSet;
    import java.util.NavigableSet;
    import java.util.Set;
    import java.util.SortedSet;
    import java.util.TreeSet;
    import java.util.concurrent.ConcurrentSkipListSet;
    import java.util.concurrent.CopyOnWriteArraySet;
    import junit.framework.Test;
    import junit.framework.TestSuite;
    
    /**
     * Generates a test suite covering the {@link Set} implementations in the {@link java.util} package.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 19 21:24:11 GMT 2025
    - 19.8K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/DescendingMultiset.java

     * limitations under the License.
     */
    
    package com.google.common.collect;
    
    import com.google.common.annotations.GwtCompatible;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.WeakOuter;
    import java.util.Comparator;
    import java.util.Iterator;
    import java.util.NavigableSet;
    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/transfer/AbstractMavenTransferListener.java

     * specific language governing permissions and limitations
     * under the License.
     */
    package org.apache.maven.cling.transfer;
    
    import java.io.PrintWriter;
    import java.time.Duration;
    import java.util.concurrent.TimeUnit;
    
    import org.apache.maven.api.MonotonicClock;
    import org.apache.maven.api.services.MessageBuilder;
    import org.apache.maven.api.services.MessageBuilderFactory;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Apr 22 22:13:51 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  8. compat/maven-model/src/test/java/org/apache/maven/model/v4/Xpp3DomPerfTest.java

    import java.io.IOException;
    import java.io.InputStream;
    import java.nio.file.Files;
    import java.nio.file.Path;
    import java.nio.file.Paths;
    import java.util.List;
    import java.util.concurrent.TimeUnit;
    import java.util.stream.Collectors;
    
    import org.apache.maven.api.model.InputSource;
    import org.openjdk.jmh.annotations.Benchmark;
    import org.openjdk.jmh.annotations.BenchmarkMode;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Sep 29 14:45:25 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java

     */
    package org.apache.maven.internal.impl;
    
    import javax.inject.Inject;
    import javax.inject.Named;
    import javax.inject.Singleton;
    
    import java.util.Objects;
    import java.util.Optional;
    import java.util.concurrent.ConcurrentHashMap;
    
    import org.apache.maven.api.JavaPathType;
    import org.apache.maven.api.Type;
    import org.apache.maven.api.annotations.Nonnull;
    import org.apache.maven.api.services.LanguageRegistry;
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed May 14 04:47:58 GMT 2025
    - 4K bytes
    - Click Count (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/ClientRuleEventListener.kt

     * limitations under the License.
     */
    package okhttp3
    
    import java.io.IOException
    import java.net.InetAddress
    import java.net.InetSocketAddress
    import java.net.Proxy
    import java.util.concurrent.TimeUnit
    
    class ClientRuleEventListener(
      var logger: (String) -> Unit,
    ) : EventListener(),
      EventListener.Factory {
      private var startNs: Long? = null
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 5.4K bytes
    - Click Count (0)
Back to Top