- Sort Score
- Result 10 results
- Languages All
Results 561 - 570 of 822 for Concurrent (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)