/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | 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);
|
H A D | 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...] |
H A D | ListenableFutureTester.java | 72 assertTrue(latch.await(5, TimeUnit.SECONDS)); 84 assertTrue(latch.await(5, TimeUnit.SECONDS)); 99 assertTrue(latch.await(5, TimeUnit.SECONDS));
|
H A D | ExecutionListTest.java | 53 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS)); 75 okayToRun.await(); 106 assertTrue(countDownLatch.await(1L, TimeUnit.SECONDS));
|
H A D | SerializingExecutorTest.java | 190 barrier.await(); 200 barrier.await(10, TimeUnit.SECONDS); 203 barrier.await(10, TimeUnit.SECONDS);
|
H A D | AbstractExecutionThreadServiceTest.java | 71 enterRun.await(); // to avoid stopping the service until run() is invoked 84 enterRun.await(); // to avoid stopping the service until run() is invoked 140 exitRun.await(); 269 enterRun.await(); 313 started.await(); 338 enterRun.await();
|
H A D | JdkFutureAdaptersTest.java | 137 submitSuccessful.await(); 183 allowGetToComplete.await(1, SECONDS); 242 assertTrue(earlyListener.wasRun.await(1, SECONDS)); 247 assertTrue(lateListener.wasRun.await(1, SECONDS));
|
H A D | ListenerCallQueueTest.java | 88 latch.await(); 114 latch.await();
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/spdy/ |
H A D | Ping.java | 55 latch.await(); 65 if (latch.await(timeout, unit)) {
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
H A D | 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));
|
H A D | 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);
|
H A D | AbstractCheckedFutureTest.java | 124 assertTrue(startingGate.await(500, TimeUnit.MILLISECONDS)); 127 assertTrue(successLatch.await(500, TimeUnit.MILLISECONDS));
|
/external/guava/guava-testlib/src/com/google/common/testing/ |
H A D | 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);
|
/external/apache-http/src/org/apache/http/impl/conn/tsccm/ |
H A D | 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/vogar/src/vogar/ |
H A D | Target.java | 33 public abstract void await(File nonEmptyDirectory); method in class:Target
|
H A D | LocalTarget.java | 48 @Override public void await(File nonEmptyDirectory) { method in class:LocalTarget
|
/external/jmonkeyengine/engine/src/core/com/jme3/app/ |
H A D | AppTask.java | 89 finishedCondition.await(); 104 finishedCondition.await(timeout, unit);
|
/external/okhttp/okhttp-ws-tests/src/test/java/com/squareup/okhttp/ws/ |
H A D | AutobahnTester.java | 108 if (!latch.await(10, TimeUnit.SECONDS)) { 144 if (!latch.await(10, TimeUnit.SECONDS)) { 180 if (!latch.await(10, TimeUnit.SECONDS)) {
|
/external/blktrace/btt/ |
H A D | 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; 129 fprintf(iostat_ofp, "%7.2lf ", await); 155 asp->await += await; 176 fprintf(iostat_ofp, "%7.2lf ", asp->await / asp->n);
|
/external/vogar/src/vogar/tasks/ |
H A D | PrepareTarget.java | 37 target.await(run.runnerDir.getParentFile().getParentFile());
|
/external/zxing/qr_scanner/src/com/google/zxing/client/android/ |
H A D | DecodeThread.java | 64 handlerInitLatch.await();
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | 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/test/com/google/common/testing/ |
H A D | FakeTickerTest.java | 158 startLatch.await(); 165 doneLatch.await();
|
H A D | GcFinalizationTest.java | 48 GcFinalization.await(latch); 130 GcFinalization.await(latch); 194 * specific finalize method as the more direct await* methods, but should be 206 // Use e.g. awaitClear or await(CountDownLatch) instead.
|
/external/droiddriver/src/io/appium/droiddriver/actions/view/ |
H A D | CloseKeyboardAction.java | 78 if (!latch.await(getTimeoutMillis(), TimeUnit.MILLISECONDS)) {
|