- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for CountDownLatch (0.25 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
SettableFuture<String> input = SettableFuture.create(); final CountDownLatch inFunction = new CountDownLatch(1); final CountDownLatch shouldCompleteFunction = new CountDownLatch(1); final CountDownLatch gotException = new CountDownLatch(1); AsyncFunction<String, String> function = new AsyncFunction<String, String>() { @Override
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
SettableFuture<String> input = SettableFuture.create(); final CountDownLatch inFunction = new CountDownLatch(1); final CountDownLatch shouldCompleteFunction = new CountDownLatch(1); final CountDownLatch gotException = new CountDownLatch(1); AsyncFunction<String, String> function = new AsyncFunction<String, String>() { @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
assertTrue(notifications.toString(), notifications.isEmpty()); } public void testCopyEntry_computing() { final CountDownLatch startSignal = new CountDownLatch(1); final CountDownLatch computingSignal = new CountDownLatch(1); final CountDownLatch doneSignal = new CountDownLatch(2); final Object computedObject = new Object(); final CacheLoader<Object, Object> loader =
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 112.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
assertEquals(1, map.size()); } public void testCopyEntry_computing() { final CountDownLatch startSignal = new CountDownLatch(1); final CountDownLatch computingSignal = new CountDownLatch(1); final CountDownLatch doneSignal = new CountDownLatch(2); final Object computedObject = new Object(); final CacheLoader<Object, Object> loader =
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Mar 14 23:06:48 GMT 2024 - 110.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
*/ CountDownLatch whenClosedCountDown() { if (closed) { return new CountDownLatch(0); } synchronized (this) { if (closed) { return new CountDownLatch(0); } checkState(whenClosed == null); return whenClosed = new CountDownLatch(1); } } } /**
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CallTest.kt
import java.net.UnknownHostException import java.net.UnknownServiceException import java.time.Duration import java.util.Arrays import java.util.concurrent.BlockingQueue import java.util.concurrent.CountDownLatch import java.util.concurrent.Executors import java.util.concurrent.SynchronousQueue import java.util.concurrent.TimeUnit import java.util.concurrent.atomic.AtomicBoolean import java.util.concurrent.atomic.AtomicInteger
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 10 19:46:48 GMT 2024 - 142.5K bytes - Viewed (0)