- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 56 for AtomicReference (0.23 sec)
-
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
import java.io.InterruptedIOException import java.net.HttpURLConnection import java.time.Duration import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicReference import kotlin.test.assertFailsWith import mockwebserver3.MockResponse import mockwebserver3.MockWebServer import okhttp3.MediaType.Companion.toMediaTypeOrNull import okhttp3.TestUtil.repeat
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/AbstractCacheTest.java
import java.util.List; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@link AbstractCache}. * * @author Charles Fry */ public class AbstractCacheTest extends TestCase { public void testGetIfPresent() { final AtomicReference<Object> valueRef = new AtomicReference<>(); Cache<Object, Object> cache =
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 19 19:24:36 GMT 2023 - 6.2K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
*/ package okhttp3 import java.util.concurrent.CountDownLatch import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicLong import java.util.concurrent.atomic.AtomicReference import okhttp3.internal.USER_AGENT import okio.ByteString /** * Exercises the web socket implementation against the * [Autobahn Testsuite](http://autobahn.ws/testsuite/). */ class AutobahnTester {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
assertSame(one, cache.getUnchecked(one)); assertFalse(segment.recencyQueue.isEmpty()); } public void testRecursiveComputation() throws InterruptedException { final AtomicReference<LoadingCache<Integer, String>> cacheRef = new AtomicReference<>(); CacheLoader<Integer, String> recursiveLoader = new CacheLoader<Integer, String>() { @Override public String load(Integer key) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Oct 10 19:45:10 GMT 2022 - 12.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
import java.net.Proxy import java.security.cert.X509Certificate import java.util.Arrays import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSession import javax.net.ssl.X509TrustManager import kotlin.test.assertFailsWith
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// Since this class only needs CAS on one field, we can avoid this bug by extending AtomicReference // instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances // and DONE/INTERRUPTED - they have a common ancestor of Runnable. abstract class InterruptibleTask<T extends @Nullable Object> extends AtomicReference<@Nullable Runnable> implements Runnable { static {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Sep 29 21:34:48 GMT 2023 - 9.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
new ThreadLocal<Integer>() { @Override protected Integer initialValue() { return 0; } }; final AtomicReference<Throwable> throwableFromOtherThread = new AtomicReference<>(null); final Runnable incrementTask = new Runnable() { @Override public void run() { threadLocalCount.set(threadLocalCount.get() + 1);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; /** * Unit test for {@link AbstractScheduledService}. * * @author Luke Sandberg */
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/helper/SystemHelperTest.java
assertEquals("ok", FileUtil.readText(fileList.get(0).toFile())); } public void test_updateSystemProperties() { final SystemHelper helper = new SystemHelper(); final AtomicReference<String> appValue = new AtomicReference<>(StringUtil.EMPTY); ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() { private static final long serialVersionUID = 1L; @Override
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 18.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/base/SuppliersTest.java
private void testSupplierThreadSafe(Function<Supplier<Boolean>, Supplier<Boolean>> memoizer) throws Throwable { final AtomicInteger count = new AtomicInteger(0); final AtomicReference<Throwable> thrown = new AtomicReference<>(null); final int numThreads = 3; final Thread[] threads = new Thread[numThreads]; final long timeout = TimeUnit.SECONDS.toNanos(60); final Supplier<Boolean> supplier =
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri Feb 09 15:49:48 GMT 2024 - 18.1K bytes - Viewed (0)