| /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);
|
