Home
last modified time | relevance | path

Searched refs:directExecutor (Results 1 – 25 of 25) sorted by relevance

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DExecutionListTest.java19 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()
DJdkFutureAdaptersTest.java22 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()
DListenerCallQueueTest.java19 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()
DListenableFutureTaskTest.java19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
69 }, directExecutor()); in setUp()
DFuturesTest.java27 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 …]
DAbstractServiceTest.java19 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()
DAbstractIdleServiceTest.java20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
213 return directExecutor(); in executor()
DMoreExecutorsTest.java33 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/
DDependentTest.java33 .executor(MoreExecutors.directExecutor()) in dependentComponent()
36 .executor(MoreExecutors.directExecutor()) in dependentComponent()
46 .executor(MoreExecutors.directExecutor()); in reuseBuilderWithDependentComponent()
50 .executor(MoreExecutors.directExecutor()) in reuseBuilderWithDependentComponent()
DProducerFactoryTest.java67 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()
DMultibindingTest.java35 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()
DSimpleTest.java30 .executor(MoreExecutors.directExecutor()) in testSimpleComponent()
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/builder/
DProductionComponentBuilderTest.java35 .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/
DFutures.java22 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 …]
DAbstractScheduledService.java19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
305 }, directExecutor());
DServiceManager.java25 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()
DMoreExecutors.java449 public static Executor directExecutor() { in directExecutor() method in MoreExecutors
753 }, directExecutor()); in submitAndAddQueueListener()
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DMockFutureListener.java19 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/
DExecutionListBenchmark.java19 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());
DMoreExecutorsDirectExecutorBenchmark.java19 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/
DMonitoringTest.java70 .executor(MoreExecutors.directExecutor()) in basicMonitoring()
110 .executor(MoreExecutors.directExecutor()) in basicMonitoringWithFailure()
/external/caliper/caliper/src/main/java/com/google/caliper/runner/
DStreamService.java151 }, MoreExecutors.directExecutor()); in doStart()
186 MoreExecutors.directExecutor()); in doStart()
DExperimentingCaliperRun.java302 }, MoreExecutors.directExecutor()); in inCompletionOrder()
/external/caliper/caliper/src/test/java/com/google/caliper/runner/
DStreamServiceTest.java234 }, MoreExecutors.directExecutor()); in makeService()
/external/guava/guava/src/com/google/common/cache/
DLocalCache.java23 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
2337 }, directExecutor()); in loadAsync()