Search Options

Results per page
Sort
Preferred Languages
Advance

Results 561 - 570 of 822 for Concurrent (0.17 sec)

  1. android/guava-tests/test/com/google/common/cache/CacheRefreshTest.java

     * the License.
     */
    
    package com.google.common.cache;
    
    import static com.google.common.cache.TestingCacheLoaders.incrementingLoader;
    import static com.google.common.truth.Truth.assertThat;
    import static java.util.concurrent.TimeUnit.MILLISECONDS;
    
    import com.google.common.cache.TestingCacheLoaders.IncrementingLoader;
    import com.google.common.testing.FakeTicker;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 4K bytes
    - Viewed (0)
  2. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

     */
    package org.codelibs.fess.crawler.service.impl;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentHashMap;
    import java.util.concurrent.ConcurrentLinkedQueue;
    import java.util.stream.Collectors;
    
    import org.apache.logging.log4j.LogManager;
    import org.apache.logging.log4j.Logger;
    import org.codelibs.core.lang.StringUtil;
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:40:57 UTC 2025
    - 16.9K bytes
    - Viewed (1)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.http
    
    import java.io.IOException
    import java.util.concurrent.TimeUnit
    import okhttp3.Call
    import okhttp3.Connection
    import okhttp3.Interceptor
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.checkDuration
    import okhttp3.internal.connection.Exchange
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/ImmutableEnumSet.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 java.io.InvalidObjectException;
    import java.io.ObjectInputStream;
    import java.io.Serializable;
    import java.util.Collection;
    import java.util.EnumSet;
    import java.util.Spliterator;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  5. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

    import java.security.SecureRandom
    import java.security.Security
    import java.security.cert.Certificate
    import java.security.cert.CertificateException
    import java.security.cert.X509Certificate
    import java.util.concurrent.atomic.AtomicInteger
    import java.util.logging.Handler
    import java.util.logging.Level
    import java.util.logging.LogRecord
    import java.util.logging.Logger
    import javax.net.ssl.HostnameVerifier
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Nov 04 19:13:52 UTC 2025
    - 29.9K bytes
    - Viewed (0)
  6. okhttp-tls/api/okhttp-tls.api

    	public final fun certificateAuthority (I)Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun commonName (Ljava/lang/String;)Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun duration (JLjava/util/concurrent/TimeUnit;)Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun ecdsa256 ()Lokhttp3/tls/HeldCertificate$Builder;
    	public final fun keyPair (Ljava/security/KeyPair;)Lokhttp3/tls/HeldCertificate$Builder;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Feb 26 19:17:33 UTC 2022
    - 3.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/AbstractSortedMultiset.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    
    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 org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 4.5K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

    import java.util.EnumMap;
    import java.util.List;
    import java.util.Map;
    import java.util.Map.Entry;
    import java.util.Set;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import java.util.logging.Level;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  9. samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java

    import okhttp3.HttpUrl;
    import okhttp3.OkHttpClient;
    import okhttp3.Protocol;
    import okhttp3.Request;
    import okhttp3.Response;
    
    /**
     * This prints events for a single in-flight call. It won't work for multiple concurrent calls
     * because we don't know what callStartNanos refers to.
     */
    public final class PrintEventsNonConcurrent {
      private final OkHttpClient client = new OkHttpClient.Builder()
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 16 23:20:49 UTC 2020
    - 5.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/eventbus/Subscriber.java

    import com.google.common.annotations.VisibleForTesting;
    import com.google.j2objc.annotations.Weak;
    import java.lang.reflect.InvocationTargetException;
    import java.lang.reflect.Method;
    import java.util.concurrent.Executor;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A subscriber method on a specific object, plus the executor that should be used for dispatching
     * events to it.
     *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed May 14 19:40:47 UTC 2025
    - 4.7K bytes
    - Viewed (0)
Back to top