/libcore/luni/src/main/java/java/util/concurrent/locks/ |
Condition.java | 58 * <b>notFull.await();</b> 72 * <b>notEmpty.await();</b> 104 * {@linkplain #await waiting} and {@linkplain #signal signalling} methods. 202 void await() throws InterruptedException; method in interface:Condition 344 boolean await(long time, TimeUnit unit) throws InterruptedException; method in interface:Condition 428 * lock before returning from {@code await}. 446 * return from {@code await}.
|
/libcore/jsr166-tests/src/test/java/jsr166/ |
CyclicBarrierTest.java | 69 * A 1-party barrier triggers after single await 75 b.await(); 76 b.await(); 88 b.await(); 89 b.await(); 95 * A 2-party/thread barrier triggers after both threads invoke await 101 b.await(); 102 b.await(); 103 b.await(); 104 b.await(); [all...] |
CountDownLatchTest.java | 51 * await returns after countDown to zero, but not before 61 l.await(); 65 await(pleaseCountDown); 76 * timed await returns after countDown to zero 86 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS)); 90 await(pleaseCountDown); 101 * await throws IE if interrupted before counted down 110 l.await(); 117 l.await(); 125 await(pleaseInterrupt) [all...] |
ExchangerTest.java | 72 await(threadStarted); 89 await(threadStarted); 129 interrupted.await(); 134 interrupted.await(); 138 await(exchanged);
|
ReentrantLockTest.java | 136 enum AwaitMethod { await, awaitTimed, awaitNanos, awaitUntil }; enum constant in enum:ReentrantLockTest.AwaitMethod 141 void await(Condition c, AwaitMethod awaitMethod) method in class:ReentrantLockTest 145 case await: 146 c.await(); 149 assertTrue(c.await(timeoutMillis, MILLISECONDS)); 441 barrier.await(); 442 barrier.await(); 446 barrier.await(); 448 barrier.await(); 479 * Calling await without holding lock throws IllegalMonitorStateExceptio 489 await(c, awaitMethod); method 983 await(c, awaitMethod); method [all...] |
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
AbstractScheduledServiceTest.java | 79 service.runFirstBarrier.await(); 80 service.runSecondBarrier.await(); 109 service.runFirstBarrier.await(); 111 service.runSecondBarrier.await(); 125 service.runFirstBarrier.await(); 127 service.runSecondBarrier.await(); 129 service.runFirstBarrier.await(); 131 service.runSecondBarrier.await(); 141 service.runFirstBarrier.await(); 143 service.runSecondBarrier.await(); [all...] |
ListenableFutureTaskTest.java | 48 taskLatch.await(); 90 runLatch.await(); 99 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); 109 runLatch.await(); 119 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS)); 131 listenerLatch.await(5, TimeUnit.SECONDS); 141 runLatch.await(); 150 listenerLatch.await(5, TimeUnit.SECONDS);
|
ListenableFutureTester.java | 69 assertTrue(latch.await(5, TimeUnit.SECONDS)); 81 assertTrue(latch.await(5, TimeUnit.SECONDS)); 96 assertTrue(latch.await(5, TimeUnit.SECONDS));
|
/frameworks/testing/espresso/espresso-lib-tests/src/androidTest/java/com/google/android/apps/common/testing/ui/espresso/base/ |
AsyncTaskPoolMonitorTest.java | 71 assertTrue(runLatch.await(1, TimeUnit.SECONDS)); 106 exitLatch.await(); 113 assertTrue(runLatch.await(1, TimeUnit.SECONDS)); 128 assertTrue(notificationLatch.await(1, TimeUnit.SECONDS)); 141 firstExitLatch.await(); 148 assertTrue(firstRunLatch.await(1, TimeUnit.SECONDS)); 165 secondExitLatch.await(); 172 assertFalse(notificationLatch.await(10, TimeUnit.MILLISECONDS)); 174 assertFalse(notificationLatch.await(500, TimeUnit.MILLISECONDS)); 176 assertTrue(notificationLatch.await(1, TimeUnit.SECONDS)) [all...] |
UiControllerImplTest.java | 69 init.await(); 78 init.await(); 174 "Timed out waiting for looper to process all events", latch.await(10, TimeUnit.SECONDS)); 197 latch.await(10, TimeUnit.SECONDS)); 231 "Timed out waiting for looper to process all events", latch.await(10, TimeUnit.SECONDS)); 247 asyncTaskShouldComplete.await(); 255 assertTrue("async task is not starting!", asyncTaskStarted.await(2, TimeUnit.SECONDS)); 284 "Should not have stopped looping the main thread yet!", latch.await(2, TimeUnit.SECONDS)); 287 assertTrue("App should be idle.", latch.await(5, TimeUnit.SECONDS)); 302 latch.await(10, TimeUnit.SECONDS)) [all...] |
IdlingResourceRegistryTest.java | 74 latch.await(); 86 latch2.await(); 104 latch.await(); 116 latch2.await(); 164 assertFalse("Expected to timeout", busyWarningLatch.await(6, TimeUnit.SECONDS)); 168 assertFalse("Expected to timeout", busyWarningLatch.await(6, TimeUnit.SECONDS)); 172 assertFalse("Expected to timeout", busyWarningLatch.await(6, TimeUnit.SECONDS)); 176 assertTrue(allResourcesIdleLatch.await(200, TimeUnit.MILLISECONDS)); 221 assertFalse("Expected to timeout", busyWarningLatch.await(6, TimeUnit.SECONDS)); 225 assertFalse("Expected to timeout", busyWarningLatch.await(6, TimeUnit.SECONDS)) [all...] |
UiControllerImplIntegrationTest.java | 115 assertTrue("Timed out!", latch.await(10, TimeUnit.SECONDS)); 137 assertTrue("requestFocus timed out!", focusLatch.await(2, TimeUnit.SECONDS)); 153 assertTrue("Timed out!", latch.await(20, TimeUnit.SECONDS)); 175 assertTrue("requestFocus timed out!", focusLatch.await(2, TimeUnit.SECONDS)); 191 assertTrue("Timed out!", latch.await(20, TimeUnit.SECONDS)); 210 assertTrue("requestFocus timed out!", focusLatch.await(2, TimeUnit.SECONDS)); 226 assertTrue("Timed out!", latch.await(20, TimeUnit.SECONDS)); 245 assertFalse("Did NOT time out!", latch.await(3, TimeUnit.SECONDS)); 276 assertTrue("Timed out!", latch.await(10, TimeUnit.SECONDS));
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
Ping.java | 55 latch.await(); 65 if (latch.await(timeout, unit)) {
|
/libcore/luni/src/main/java/java/util/concurrent/ |
CountDownLatch.java | 15 * The {@link #await await} methods block until the current count reaches 18 * {@link #await await} return immediately. This is a one-shot phenomenon 25 * simple on/off latch, or gate: all threads invoking {@link #await await} 34 * thread from proceeding past an {@link #await await} until all 58 * doneSignal.await(); // wait for all to finish 71 * startSignal.await(); 201 public void await() throws InterruptedException { method in class:CountDownLatch 246 public boolean await(long timeout, TimeUnit unit) method in class:CountDownLatch [all...] |
CyclicBarrier.java | 42 * barrier.await(); 78 * {@link #await} returns the arrival index of that thread at the barrier. 82 * if (barrier.await() == 0) { 95 * {@code await()} 99 * corresponding {@code await()} in other threads. 201 trip.await(); 238 * @param parties the number of threads that must invoke {@link #await} 256 * @param parties the number of threads that must invoke {@link #await} 275 * {@code await} on this barrier. 300 * {@code await} is invoked, or while any thread is waiting, the 327 public int await() throws InterruptedException, BrokenBarrierException { method in class:CyclicBarrier 397 public int await(long timeout, TimeUnit unit) method in class:CyclicBarrier [all...] |
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
MockFutureListener.java | 61 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); 77 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); 90 Assert.assertFalse(countDownLatch.await(1L, TimeUnit.SECONDS));
|
AbstractListenableFutureTest.java | 96 assertTrue(successLatch.await(10, TimeUnit.SECONDS)); 158 assertTrue(successLatch.await(200, TimeUnit.MILLISECONDS)); 194 assertTrue(successLatch.await(200, TimeUnit.MILLISECONDS)); 195 assertTrue(listenerLatch.await(200, TimeUnit.MILLISECONDS)); 241 listenerLatch.await(500, TimeUnit.MILLISECONDS);
|
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/ |
AsyncResultHolder.java | 62 if (mLatch.await(timeOut, TimeUnit.MILLISECONDS)) {
|
/cts/apps/CtsVerifier/src/com/android/cts/verifier/jobscheduler/ |
MockJobService.java | 83 final boolean executed = mLatch.await(DEFAULT_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); 93 return !mLatch.await(DEFAULT_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
|
/cts/tests/JobScheduler/src/android/jobscheduler/ |
MockJobService.java | 83 final boolean executed = mLatch.await(DEFAULT_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS); 93 return !mLatch.await(DEFAULT_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
|
/cts/tests/tests/hardware/src/android/hardware/cts/helpers/ |
ActivityResultMultiplexedLatch.java | 53 public int await() throws InterruptedException { method in class:ActivityResultMultiplexedLatch.Latch 54 mEntry.latch.await();
|
/external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
WaitingThread.java | 137 public boolean await(Date deadline) method in class:WaitingThread 141 // the lock would not be released on calling cond.await() below. 159 this.cond.await(); 169 } // await
|
/external/guava/guava-tests/test/com/google/common/testing/ |
FakeTickerTest.java | 62 startLatch.await(); 71 doneLatch.await();
|
/external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/ |
AsyncApiTest.java | 72 receiver.await(request.url()) 87 receiver.await(server.getUrl("/a")).assertBody("abc"); 90 receiver.await(server.getUrl("/b")).assertBody("def"); 93 receiver.await(server.getUrl("/c")).assertBody("ghi"); 115 receiver.await(request.url()).assertHandshake(); 132 receiver.await(request.url()).assertBody("abc"); 145 receiver.await(request.url()) 168 receiver.await(request1.url()).assertCode(200).assertBody("A"); 175 receiver.await(request2.url()).assertCode(200).assertBody("A"); 190 receiver.await(request1.url()).assertCode(200).assertBody("A") [all...] |
/external/guava/guava-testlib/src/com/google/common/testing/ |
GcFinalization.java | 61 * GcFinalization.await(latch); 150 public static void await(CountDownLatch latch) { method in class:GcFinalization 163 if (latch.await(1L, SECONDS)) { 216 await(done);
|