| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| DependentTest.java | 33 .executor(MoreExecutors.directExecutor())
36 .executor(MoreExecutors.directExecutor())
46 .executor(MoreExecutors.directExecutor());
50 .executor(MoreExecutors.directExecutor())
|
| MultibindingTest.java | 35 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build();
44 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build();
58 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build();
|
| ProducerFactoryTest.java | 67 MoreExecutors.directExecutor(), componentMonitorProvider);
82 MoreExecutors.directExecutor(), componentMonitorProvider, intProducer);
97 MoreExecutors.directExecutor(), componentMonitorProvider, strFutureProducer);
124 MoreExecutors.directExecutor(), componentMonitorProvider, strFutureProducer);
154 MoreExecutors.directExecutor(), componentMonitorProvider);
175 new SimpleProducerModule_StrFactory(MoreExecutors.directExecutor(), null);
|
| SimpleTest.java | 30 .executor(MoreExecutors.directExecutor())
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
61 }, directExecutor());
81 }, directExecutor());
118 MoreExecutors.directExecutor());
137 list.add(THROWING_RUNNABLE, directExecutor());
139 list.add(THROWING_RUNNABLE, directExecutor());
|
| ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
44 new ListenerCallQueue<Object>(listenerInstance, directExecutor());
59 new ListenerCallQueue<Object>(listenerInstance, directExecutor());
|
| JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
59 ExecutorSpy spy = new ExecutorSpy(directExecutor());
72 listenableFuture.addListener(singleCallListener, directExecutor());
131 listenableFuture.addListener(singleCallListener, directExecutor());
238 listenable.addListener(earlyListener, directExecutor());
246 listenable.addListener(lateListener, directExecutor());
|
| ListenableFutureTaskTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
69 }, directExecutor());
|
| AbstractIdleServiceTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
213 return directExecutor();
|
| FuturesTest.java | 27 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
441 ExecutorSpy spy = new ExecutorSpy(directExecutor());
828 compound.addListener(listener, directExecutor());
850 compound.addListener(listener, directExecutor());
861 compound.addListener(listener, directExecutor());
[all...] |
| AbstractServiceTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
262 }, directExecutor());
690 service.addListener(new RecordingListener(service), directExecutor());
708 }, directExecutor());
719 }, directExecutor());
816 service.addListener(listener, directExecutor());
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/builder/ |
| ProductionComponentBuilderTest.java | 35 .executor(MoreExecutors.directExecutor())
47 .executor(MoreExecutors.directExecutor())
65 .executor(MoreExecutors.directExecutor())
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MoreExecutorsDirectExecutorBenchmark.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
36 * {@link MoreExecutors#directExecutor}.
48 return directExecutor();
|
| ExecutionListBenchmark.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
190 list.add(listener, directExecutor());
201 list.add(listener, directExecutor());
217 list.add(listener, directExecutor());
235 list.add(listener, directExecutor());
257 list.add(listener, directExecutor());
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListenableFuture.java | 100 * MoreExecutors#directExecutor direct execution}) will be caught and
104 * any thread, consider {@link MoreExecutors#directExecutor}. For heavier
105 * listeners, {@code directExecutor()} carries some caveats. For
118 * {@code directExecutor()} listener, all other registered but unexecuted
|
| ExecutionList.java | 40 * MoreExecutors#directExecutor direct execution}) will be caught and
69 * any thread, consider {@link MoreExecutors#directExecutor}. For heavier
70 * listeners, {@code directExecutor()} carries some caveats: First, the
75 * as an RPC network thread, and {@code directExecutor()} listeners may
77 * directExecutor} listener, all other registered but unexecuted
|
| Futures.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
353 * {@linkplain MoreExecutors#directExecutor direct executor}, which carries
379 return withFallback(input, fallback, directExecutor());
406 * }, directExecutor());}</pre>
424 * }, directExecutor());}</pre>
430 * directExecutor}. However, be aware of the caveats documented in the
490 }, directExecutor());
531 * {@linkplain MoreExecutors#directExecutor direct executor}, which carries
567 input.addListener(output, directExecutor());
599 * the executor} or explicitly specifying {@code directExecutor}
[all...] |
| MoreExecutors.java | 266 * @deprecated Use {@link #directExecutor()} if you only require an {@link Executor} and
438 * final class DirectExecutor implements Executor {
449 public static Executor directExecutor() {
450 return DirectExecutor.INSTANCE;
453 /** See {@link #directExecutor} for behavioral notes. */
454 private enum DirectExecutor implements Executor {
753 }, directExecutor());
[all...] |
| AbstractScheduledService.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
305 }, directExecutor());
|
| /external/dagger2/producers/src/main/java/dagger/producers/ |
| Producer.java | 71 * .executor(MoreExecutors.directExecutor())
79 * Here, we're using {@code MoreExecutors.directExecutor} in order to illustrate how each call
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| MockFutureListener.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
46 future.addListener(this, directExecutor());
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/monitoring/ |
| MonitoringTest.java | 70 .executor(MoreExecutors.directExecutor())
110 .executor(MoreExecutors.directExecutor())
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| Executor.java | 29 * class DirectExecutor implements Executor {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| StreamService.java | 151 }, MoreExecutors.directExecutor());
186 MoreExecutors.directExecutor());
|
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| StreamServiceTest.java | 234 }, MoreExecutors.directExecutor());
|
