/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 61 }, directExecutor()); in testExecute_idempotent() 81 }, directExecutor()); in testExecute_idempotentConcurrently() 118 MoreExecutors.directExecutor()); in testOrdering() 137 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught() 139 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
|
D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 59 ExecutorSpy spy = new ExecutorSpy(directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone() 72 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone() 131 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadCustomExecutorInterrupted() 238 listenable.addListener(earlyListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException() 246 listenable.addListener(lateListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 44 new ListenerCallQueue<Object>(listenerInstance, directExecutor()); in testAddAndExecute() 59 new ListenerCallQueue<Object>(listenerInstance, directExecutor()); in testAddAndExecute_withExceptions()
|
D | ListenableFutureTaskTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 69 }, directExecutor()); in setUp()
|
D | 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()); 874 compound.addListener(listener, directExecutor()); 940 compound.addListener(listener, directExecutor()); 1011 compound.addListener(listener, directExecutor()); 1471 compound.addListener(listener, directExecutor()); 1493 compound.addListener(listener, directExecutor()); [all …]
|
D | AbstractServiceTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 262 }, directExecutor()); in testManualServiceStopMultipleTimesWhileStarting() 690 service.addListener(new RecordingListener(service), directExecutor()); in testAddListenerAfterFailureDoesntCauseDeadlock() 708 }, directExecutor()); in testListenerDoesntDeadlockOnStartAndWaitFromRunning() 719 }, directExecutor()); in testListenerDoesntDeadlockOnStopAndWaitFromTerminated() 816 service.addListener(listener, directExecutor()); in record()
|
D | AbstractIdleServiceTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 213 return directExecutor(); in executor()
|
D | MoreExecutorsTest.java | 33 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 499 future.addListener(listener, directExecutor()); in assertListenerRunImmediately()
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
D | DependentTest.java | 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 | ProducerFactoryTest.java | 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 | MultibindingTest.java | 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 | SimpleTest.java | 30 .executor(MoreExecutors.directExecutor()) in testSimpleComponent()
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/builder/ |
D | ProductionComponentBuilderTest.java | 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 | Futures.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 379 return withFallback(input, fallback, directExecutor()); in withFallback() 490 }, directExecutor()); in FallbackFuture() 567 input.addListener(output, directExecutor()); in transform() 616 input.addListener(rejectionPropagatingRunnable(output, output, executor), directExecutor()); in transform() 708 input.addListener(output, directExecutor()); 933 }, directExecutor()); 1005 return listFuture(ImmutableList.copyOf(futures), true, directExecutor()); 1027 return listFuture(ImmutableList.copyOf(futures), true, directExecutor()); 1115 }, directExecutor()); [all …]
|
D | AbstractScheduledService.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 305 }, directExecutor());
|
D | ServiceManager.java | 25 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 207 service.addListener(new ServiceListener(service, stateReference), directExecutor()); in ServiceManager() 261 state.addListener(listener, directExecutor()); in addListener()
|
D | MoreExecutors.java | 449 public static Executor directExecutor() { in directExecutor() method in MoreExecutors 753 }, directExecutor()); in submitAndAddQueueListener()
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
D | MockFutureListener.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 46 future.addListener(this, directExecutor()); in MockFutureListener()
|
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
D | 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());
|
D | MoreExecutorsDirectExecutorBenchmark.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 48 return directExecutor(); in executor()
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/monitoring/ |
D | MonitoringTest.java | 70 .executor(MoreExecutors.directExecutor()) in basicMonitoring() 110 .executor(MoreExecutors.directExecutor()) in basicMonitoringWithFailure()
|
/external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
D | StreamService.java | 151 }, MoreExecutors.directExecutor()); in doStart() 186 MoreExecutors.directExecutor()); in doStart()
|
D | ExperimentingCaliperRun.java | 302 }, MoreExecutors.directExecutor()); in inCompletionOrder()
|
/external/caliper/caliper/src/test/java/com/google/caliper/runner/ |
D | StreamServiceTest.java | 234 }, MoreExecutors.directExecutor()); in makeService()
|
/external/guava/guava/src/com/google/common/cache/ |
D | LocalCache.java | 23 import static com.google.common.util.concurrent.MoreExecutors.directExecutor; 2337 }, directExecutor()); in loadAsync()
|