| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| D | DependentTest.java | 20 import com.google.common.util.concurrent.MoreExecutors;
33 .executor(MoreExecutors.directExecutor()) in dependentComponent()
36 .executor(MoreExecutors.directExecutor()) in dependentComponent()
46 .executor(MoreExecutors.directExecutor()); in reuseBuilderWithDependentComponent()
50 .executor(MoreExecutors.directExecutor()) in reuseBuilderWithDependentComponent()
|
| D | MultibindingTest.java | 19 import com.google.common.util.concurrent.MoreExecutors;
35 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build(); in setBinding()
44 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build(); in setBindingOfProduced()
58 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build(); in setBindingOfProducedWithFailures()
|
| D | ProducerFactoryTest.java | 19 import com.google.common.util.concurrent.MoreExecutors;
67 MoreExecutors.directExecutor(), componentMonitorProvider); in noArgMethod()
82 MoreExecutors.directExecutor(), componentMonitorProvider, intProducer); in singleArgMethod()
97 MoreExecutors.directExecutor(), componentMonitorProvider, strFutureProducer); in successMonitor()
124 MoreExecutors.directExecutor(), componentMonitorProvider, strFutureProducer); in failureMonitor()
154 MoreExecutors.directExecutor(), componentMonitorProvider); in failureMonitorDueToThrowingProducer()
175 new SimpleProducerModule_StrFactory(MoreExecutors.directExecutor(), null); in nullComponentMonitorProvider()
|
| D | SimpleTest.java | 18 import com.google.common.util.concurrent.MoreExecutors;
30 .executor(MoreExecutors.directExecutor()) in testSimpleComponent()
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/builder/ |
| D | ProductionComponentBuilderTest.java | 20 import com.google.common.util.concurrent.MoreExecutors;
35 .executor(MoreExecutors.directExecutor()) in successfulBuild()
47 .executor(MoreExecutors.directExecutor()) in successfulBuild_withMissingZeroArgModule()
65 .executor(MoreExecutors.directExecutor()) in missingDepComponent()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractIdleService.java | 50 MoreExecutors.renamingDecorator(executor(), threadNameSupplier)
65 MoreExecutors.renamingDecorator(executor(), threadNameSupplier)
100 MoreExecutors.newThread(threadNameSupplier.get(), command).start(); in executor()
|
| D | AbstractExecutionThreadService.java | 46 Executor executor = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() {
146 MoreExecutors.newThread(serviceName(), command).start(); in executor()
|
| D | AbstractScheduledService.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
191 executorService = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() {
290 return MoreExecutors.newThread(serviceName(), runnable);
|
| D | MoreExecutors.java | 65 public final class MoreExecutors { class
66 private MoreExecutors() {} in MoreExecutors() method in MoreExecutors
195 addShutdownHook(MoreExecutors.newThread("DelayedShutdownHook-for-" + service, new Runnable() { in addDelayedShutdownHook()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | MoreExecutorsTest.java | 33 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
34 import static com.google.common.util.concurrent.MoreExecutors.invokeAnyImpl;
35 import static com.google.common.util.concurrent.MoreExecutors.listeningDecorator;
36 import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
37 import static com.google.common.util.concurrent.MoreExecutors.renamingDecorator;
38 import static com.google.common.util.concurrent.MoreExecutors.shutdownAndAwaitTermination;
51 import com.google.common.util.concurrent.MoreExecutors.Application;
587 ThreadFactory factory = MoreExecutors.platformThreadFactory(); in testPlatformThreadFactory_default()
607 .forAllPublicStaticMethods(MoreExecutors.class) in testExecutors_nullCheck()
|
| D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
118 MoreExecutors.directExecutor()); in testOrdering()
|
| D | ListenableFutureTaskTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
|
| D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
|
| D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
|
| D | AbstractIdleServiceTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/ |
| D | BadExecutorTest.java | 6 import com.google.common.util.concurrent.MoreExecutors;
31 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in setUpComponent()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | MoreExecutorsDirectExecutorBenchmark.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
20 import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | StreamService.java | 34 import com.google.common.util.concurrent.MoreExecutors;
88 private final ListeningExecutorService streamExecutor = MoreExecutors.listeningDecorator(
151 }, MoreExecutors.directExecutor()); in doStart()
186 MoreExecutors.directExecutor()); in doStart()
|
| D | ExperimentingRunnerModule.java | 36 import com.google.common.util.concurrent.MoreExecutors;
86 return MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(poolSize)); in provideExecutorService()
|
| D | ExperimentingCaliperRun.java | 37 import com.google.common.util.concurrent.MoreExecutors;
302 }, MoreExecutors.directExecutor()); in inCompletionOrder()
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/monitoring/ |
| D | MonitoringTest.java | 21 import com.google.common.util.concurrent.MoreExecutors;
70 .executor(MoreExecutors.directExecutor()) in basicMonitoring()
110 .executor(MoreExecutors.directExecutor()) in basicMonitoringWithFailure()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | MockFutureListener.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
|
| D | TestingExecutors.java | 26 import com.google.common.util.concurrent.MoreExecutors;
|
| D | SameThreadScheduledExecutorService.java | 19 import static com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService;
|
| /external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
| D | StreamServiceTest.java | 33 import com.google.common.util.concurrent.MoreExecutors;
234 }, MoreExecutors.directExecutor()); in makeService()
|