| /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 | 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/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);
|
| /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);
|
| /external/guava/guava-tests/test/com/google/common/testing/ |
| FakeTickerTest.java | 62 startLatch.await();
71 doneLatch.await();
|
| /external/okhttp/src/test/java/com/squareup/okhttp/internal/ |
| AsyncApiTest.java | 50 receiver.await(request)
67 receiver.await(request)
|
| /cts/tests/acceleration/src/android/acceleration/cts/ |
| AcceleratedView.java | 56 if (mDrawLatch.await(1, TimeUnit.SECONDS)) {
|
| /cts/tools/cts-holo-generation/src/com/android/cts/holo_capture/ |
| CaptureActivity.java | 31 mLatch.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/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/hostsidetests/holo/app/src/android/holo/app/ |
| CaptureActivity.java | 85 mLatch.await();
|
| /cts/tests/src/android/app/cts/ |
| ActivityManagerMemoryClassLaunchActivity.java | 68 mLatch.await(5, TimeUnit.SECONDS);
|
