/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}.
|
/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));
|
ExecutionListTest.java | 52 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); 62 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS));
|
MoreExecutorsTest.java | 143 barrier.await(1, TimeUnit.SECONDS); 146 barrier.await(1, TimeUnit.SECONDS); 151 barrier.await(1, TimeUnit.SECONDS); 166 barrier.await(1, TimeUnit.SECONDS); 181 barrier.await(1, TimeUnit.SECONDS); 185 barrier.await(1, TimeUnit.SECONDS);
|
/external/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);
|
AbstractCheckedFutureTest.java | 124 assertTrue(startingGate.await(500, TimeUnit.MILLISECONDS)); 127 assertTrue(successLatch.await(500, TimeUnit.MILLISECONDS));
|
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/ |
AsyncResultHolder.java | 62 if(mLatch.await(timeOut, TimeUnit.MILLISECONDS)) {
|
/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/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);
|
/cts/tests/acceleration/src/android/acceleration/cts/ |
AcceleratedView.java | 56 if (mDrawLatch.await(1, TimeUnit.SECONDS)) {
|
/cts/tests/src/android/app/cts/ |
ActivityManagerMemoryClassLaunchActivity.java | 68 mLatch.await(5, TimeUnit.SECONDS);
|
/external/jmonkeyengine/engine/src/core/com/jme3/app/ |
AppTask.java | 89 finishedCondition.await(); 104 finishedCondition.await(timeout, unit);
|
/external/okhttp/src/test/java/com/squareup/okhttp/internal/ |
AsyncApiTest.java | 50 receiver.await(request) 67 receiver.await(request)
|
/external/guava/guava-tests/test/com/google/common/collect/ |
MapMakerTest.java | 74 computationStarted.await(); 79 computationComplete.await(); 149 tasksFinished.await();
|
/packages/apps/ContactsCommon/tests/src/com/android/contacts/common/database/ |
NoNullCursorAsyncQueryHandlerTest.java | 80 latch.await(5, TimeUnit.SECONDS); 107 latch.await(5, TimeUnit.SECONDS); 134 latch.await(5, TimeUnit.SECONDS);
|
/cts/tests/tests/hardware/src/android/hardware/cts/ |
SensorTest.java | 203 eventReceived.await(); 206 flushReceived.await(); 240 eventReceived.await(); 243 flushReceived.await(); 278 eventReceived.await(); 281 flushReceived.await();
|
/external/blktrace/btt/ |
iostat.c | 60 "avgrq-sz avgqu-sz await svctm %%util Stamp\n"); 87 double dt, nios, avgrq_sz, p_util, nrqm, await, svctm; local 109 await = ((nios + nrqm) > 0.0) ? TO_MSEC(sp->wait) / (nios+nrqm) : 0.0; 114 * For AWAIT: nios should be the same as number of inserts 129 fprintf(iostat_ofp, "%7.2lf ", await); 155 asp->await += await; 176 fprintf(iostat_ofp, "%7.2lf ", asp->await / asp->n);
|
/frameworks/base/core/java/android/speech/tts/ |
SynthesisPlaybackQueueItem.java | 184 mNotFull.await(); 210 mReadReady.await();
|