| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| Condition.java | 59 * <b>notFull.await();</b>
73 * <b>notEmpty.await();</b>
105 * {@linkplain #await waiting} and {@linkplain #signal signalling} methods.
203 void await() throws InterruptedException; method in interface:Condition
345 boolean await(long time, TimeUnit unit) throws InterruptedException; method in interface:Condition
429 * lock before returning from {@code await}.
447 * return from {@code await}.
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| CyclicBarrierTest.java | 80 * A 1-party barrier triggers after single await
86 b.await();
87 b.await();
99 b.await();
100 b.await();
106 * A 2-party/thread barrier triggers after both threads invoke await
112 b.await();
113 b.await();
114 b.await();
115 b.await();
[all...] |
| CountDownLatchTest.java | 62 * await returns after countDown to zero, but not before
72 l.await();
76 await(pleaseCountDown);
87 * timed await returns after countDown to zero
97 assertTrue(l.await(LONG_DELAY_MS, MILLISECONDS));
101 await(pleaseCountDown);
112 * await throws IE if interrupted before counted down
121 l.await();
128 l.await();
136 await(pleaseInterrupt)
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractScheduledServiceTest.java | 77 service.runFirstBarrier.await();
78 service.runSecondBarrier.await();
107 service.runFirstBarrier.await();
109 service.runSecondBarrier.await();
123 service.runFirstBarrier.await();
125 service.runSecondBarrier.await();
127 service.runFirstBarrier.await();
129 service.runSecondBarrier.await();
139 service.runFirstBarrier.await();
141 service.runSecondBarrier.await();
[all...] |
| ListenableFutureTaskTest.java | 50 taskLatch.await();
92 runLatch.await();
101 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS));
111 runLatch.await();
121 assertTrue(listenerLatch.await(5, TimeUnit.SECONDS));
133 listenerLatch.await(5, TimeUnit.SECONDS);
143 runLatch.await();
152 listenerLatch.await(5, TimeUnit.SECONDS);
|
| /cts/tests/tests/location/src/android/location/cts/ |
| TestUtils.java | 30 // even if the main thread has called await() to yield its execution, the background thread
35 // to deliver the PendingIntent if we simply call await() on the main thread. In order to
42 if (latch.await(STANDARD_WAIT_TIME_MS, TimeUnit.MILLISECONDS)) {
|
| GnssNavigationMessageRegistrationTest.java | 97 mTestGnssNavigationMessageListener.await();
120 mLocationListener.await();
128 mGpsStatusListener.await();
|
| GnssMeasurementRegistrationTest.java | 96 mMeasurementListener.await();
122 mLocationListener.await();
|
| /external/guice/core/test/com/google/inject/internal/ |
| CycleDetectingLockTest.java | 45 signal3.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS);
61 signal2.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS);
62 signal3.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS);
76 signal1.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS);
89 signal1.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS);
90 signal2.await(DEADLOCK_TIMEOUT_SECONDS, TimeUnit.SECONDS);
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| Ping.java | 55 latch.await();
65 if (latch.await(timeout, unit)) {
|
| /external/sl4a/Utils/src/com/googlecode/android_scripting/future/ |
| FutureResult.java | 45 mLatch.await();
51 mLatch.await(timeout, unit);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| CountDownLatch.java | 16 * The {@link #await await} methods block until the current count reaches
19 * {@link #await await} return immediately. This is a one-shot phenomenon
26 * simple on/off latch, or gate: all threads invoking {@link #await await}
35 * thread from proceeding past an {@link #await await} until all
59 * doneSignal.await(); // wait for all to finish
72 * startSignal.await();
202 public void await() throws InterruptedException { method in class:CountDownLatch
247 public boolean await(long timeout, TimeUnit unit) method in class:CountDownLatch
[all...] |
| /cts/tests/tests/voiceinteraction/src/android/voiceinteraction/cts/ |
| LocalVoiceInteractionTest.java | 68 VoiceInteractionTestReceiver.sServiceStartedLatch.await(5, TimeUnit.SECONDS);
73 if (!mLatchStart.await(TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
78 if (!mLatchStop.await(TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| MockFutureListener.java | 62 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS));
78 Assert.assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS));
91 Assert.assertFalse(countDownLatch.await(1L, TimeUnit.SECONDS));
|
| /frameworks/base/core/tests/coretests/src/android/transition/ |
| FadeTransitionTest.java | 51 assertTrue(latch.startLatch.await(200, TimeUnit.MILLISECONDS));
55 assertTrue(latch.endLatch.await(400, TimeUnit.MILLISECONDS));
61 assertTrue(latch.startLatch.await(200, TimeUnit.MILLISECONDS));
67 assertTrue(latch.endLatch.await(400, TimeUnit.MILLISECONDS));
79 assertTrue(outLatch.startLatch.await(200, TimeUnit.MILLISECONDS));
86 assertTrue(inLatch.startLatch.await(200, TimeUnit.MILLISECONDS));
94 assertTrue(inLatch.endLatch.await(400, TimeUnit.MILLISECONDS));
112 assertTrue(inLatch.startLatch.await(200, TimeUnit.MILLISECONDS));
119 assertTrue(outLatch.startLatch.await(200, TimeUnit.MILLISECONDS));
127 assertTrue(outLatch.endLatch.await(400, TimeUnit.MILLISECONDS))
[all...] |
| /external/guava/guava-testlib/src/com/google/common/testing/ |
| GcFinalization.java | 61 * GcFinalization.await(latch);}</pre>
165 public static void await(CountDownLatch latch) { method in class:GcFinalization
178 if (latch.await(1L, SECONDS)) {
231 await(done);
291 await(finalizerRan);
|
| /frameworks/support/v4/tests/java/android/support/v4/view/ |
| ViewPropertyAnimatorCompatTest.java | 66 assertTrue(latch1.await(300, TimeUnit.MILLISECONDS));
84 assertTrue(latch2.await(200, TimeUnit.MILLISECONDS));
102 assertTrue(latch1.await(100, TimeUnit.MILLISECONDS));
120 assertTrue(latch2.await(200, 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 | 87 final boolean executed = mLatch.await(DEFAULT_TIMEOUT_MILLIS, TimeUnit.MILLISECONDS);
97 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();
|
| SuspendStateMonitor.java | 50 latch.await();
53 boolean countZero = latch.await(numSeconds, TimeUnit.SECONDS);
|
| /external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
| WaitingThread.java | 142 public boolean await(Date deadline) method in class:WaitingThread
146 // the lock would not be released on calling cond.await() below.
164 this.cond.await();
174 } // await
|
| /external/guice/core/test/com/google/inject/ |
| BindingOrderTest.java | 76 ready.await();
90 done.await();
|
| /external/sl4a/Common/src/com/googlecode/android_scripting/facade/ |
| TextToSpeechFacade.java | 59 mOnInitLock.await();
67 mOnInitLock.await();
|
| /frameworks/base/packages/DocumentsUI/tests/src/com/android/documentsui/services/ |
| TestContentResolver.java | 65 if (!mNotificationSignal.await(timeOut, TimeUnit.MILLISECONDS)) {
74 mReadySignal.await();
|
