- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 883 for Concurrent (0.06 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static org.junit.Assert.assertThrows; import java.lang.reflect.Method; import java.net.URLClassLoader; import java.util.HashMap; import java.util.Map; import java.util.concurrent.CancellationException; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static org.junit.Assert.assertThrows; import java.lang.reflect.Method; import java.net.URLClassLoader; import java.util.HashMap; import java.util.Map; import java.util.concurrent.CancellationException; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
import java.lang.ref.WeakReference; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.logging.Logger; import junit.framework.TestCase;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
*/ package com.google.common.util.concurrent; import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import static java.util.concurrent.TimeUnit.SECONDS; import com.google.common.testing.NullPointerTester; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.Executors; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
import com.google.common.collect.Lists; import java.util.Collection; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import junit.framework.TestCase; /** * Test for {@link WrappingExecutorService} *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 9.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ForwardingConcurrentMap.java
import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import java.util.concurrent.ConcurrentMap; import javax.annotation.CheckForNull; /** * A concurrent map which forwards all its method calls to another concurrent map. Subclasses should * override one or more methods to modify the behavior of the backing map as desired per the <a
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jun 29 19:42:21 UTC 2021 - 2.5K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun maxAge (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder; public final fun maxAge-LRDsOJo (J)Lokhttp3/CacheControl$Builder; public final fun maxStale (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder; public final fun maxStale-LRDsOJo (J)Lokhttp3/CacheControl$Builder; public final fun minFresh (ILjava/util/concurrent/TimeUnit;)Lokhttp3/CacheControl$Builder;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 15 13:41:01 UTC 2024 - 70.2K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/LongAdder.java
public void decrement() { add(-1L); } /** * Returns the current sum. The returned value is NOT an atomic snapshot; invocation in * the absence of concurrent updates returns an accurate result, but concurrent updates that occur * while the sum is being calculated might not be incorporated. * * @return the sum */ @Override public long sum() { long sum = base;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 20 18:43:59 UTC 2021 - 5.4K bytes - Viewed (0) -
guava/src/com/google/common/hash/LongAdder.java
public void decrement() { add(-1L); } /** * Returns the current sum. The returned value is NOT an atomic snapshot; invocation in * the absence of concurrent updates returns an accurate result, but concurrent updates that occur * while the sum is being calculated might not be incorporated. * * @return the sum */ @Override public long sum() { long sum = base;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 20 18:43:59 UTC 2021 - 5.4K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
import java.io.IOException; import java.util.Collections; import java.util.LinkedHashSet; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicInteger; import okhttp3.Cache; import okhttp3.HttpUrl; import okhttp3.MediaType; import okhttp3.OkHttpClient;
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 4.6K bytes - Viewed (0)