| /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));
|
| 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);
|
| ExecutionListTest.java | 52 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS));
62 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS));
|
| AbstractExecutionThreadServiceTest.java | 65 enterRun.await(); // to avoid stopping the service until run() is invoked
84 enterRun.await(); // to avoid stopping the service until run() is invoked
145 exitRun.await();
263 enterRun.await();
|
| /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 | 41 * barrier.await();
77 * {@link #await} returns the arrival index of that thread at the barrier.
81 * if (barrier.await() == 0) {
94 * {@code await()}
98 * corresponding {@code await()} in other threads.
200 trip.await();
237 * @param parties the number of threads that must invoke {@link #await}
255 * @param parties the number of threads that must invoke {@link #await}
274 * <tt>await</tt> on this barrier.
299 * <tt>await</tt> is invoked, or while any thread is waiting, the
326 public int await() throws InterruptedException, BrokenBarrierException { method in class:CyclicBarrier
396 public int await(long timeout, TimeUnit unit) method in class:CyclicBarrier
[all...] |
| /external/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
| Ping.java | 55 latch.await();
65 if (latch.await(timeout, unit)) {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| Uninterruptibles.java | 47 * Invokes {@code latch.}{@link CountDownLatch#await() await()}
55 latch.await();
70 * {@code latch.}{@link CountDownLatch#await(long, TimeUnit)
71 * await(timeout, unit)} uninterruptibly.
83 return latch.await(remainingNanos, NANOSECONDS);
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| 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);
|
| 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));
|
| AbstractCheckedFutureTest.java | 124 assertTrue(startingGate.await(500, TimeUnit.MILLISECONDS));
127 assertTrue(successLatch.await(500, TimeUnit.MILLISECONDS));
|
| /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);
|
| /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);
|
| /external/guava/guava-tests/test/com/google/common/testing/ |
| FakeTickerTest.java | 62 startLatch.await();
71 doneLatch.await();
|
| /cts/tests/acceleration/src/android/acceleration/cts/ |
| AcceleratedView.java | 56 if (mDrawLatch.await(1, TimeUnit.SECONDS)) {
|
| /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/jmonkeyengine/engine/src/core/com/jme3/app/ |
| AppTask.java | 89 finishedCondition.await();
104 finishedCondition.await(timeout, unit);
|
| /external/smack/src/com/kenai/jbosh/ |
| CMSessionParams.java | 55 final AttrWait aWait,
67 wait = aWait;
|
| /cts/tests/src/android/app/cts/ |
| ActivityManagerMemoryClassLaunchActivity.java | 68 mLatch.await(5, TimeUnit.SECONDS);
|
| /cts/tests/src/android/opengl/cts/ |
| EglConfigStubActivity.java | 88 if (!mFinishedDrawing.await(3, TimeUnit.SECONDS)) {
|
| /cts/tests/tests/media/src/android/media/cts/ |
| ScannerNotificationReceiver.java | 47 if (!mLatch.await(TIMEOUT_MS, TimeUnit.MILLISECONDS)) {
|
| /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);
|
| /external/zxing/qr_scanner/src/com/google/zxing/client/android/ |
| DecodeThread.java | 64 handlerInitLatch.await();
|
