| /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 | 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 | 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 | SimpleTest.java | 18 import com.google.common.util.concurrent.MoreExecutors;
30 .executor(MoreExecutors.directExecutor()) in testSimpleComponent()
|
| /external/opencensus-java/contrib/agent/src/jmh/java/io/opencensus/contrib/agent/instrumentation/ |
| D | ExecutorInstrumentationBenchmark.java | 19 import com.google.common.util.concurrent.MoreExecutors;
56 MoreExecutors.directExecutor().execute(new MyRunnable(blackhole)); in none()
69 MoreExecutors.directExecutor().execute(Context.current().wrap(new MyRunnable(blackhole))); in manual()
82 MoreExecutors.directExecutor().execute(new MyRunnable(blackhole)); in automatic()
|
| /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/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ClientCallImplTest.java | 40 import com.google.common.util.concurrent.MoreExecutors;
276 MoreExecutors.directExecutor(), in advertisedEncodingsAreSent()
300 MoreExecutors.directExecutor(), in authorityPropagatedToStream()
317 MoreExecutors.directExecutor(), in callOptionsPropagatedToTransport()
335 MoreExecutors.directExecutor(), in authorityNotPropagatedToStream()
683 MoreExecutors.directExecutor(), in contextDeadlineShouldBePropagatedToStream()
708 MoreExecutors.directExecutor(), in contextDeadlineShouldOverrideLargerCallOptionsDeadline()
733 MoreExecutors.directExecutor(), in contextDeadlineShouldNotOverrideSmallerCallOptionsDeadline()
754 MoreExecutors.directExecutor(), in callOptionsDeadlineShouldBePropagatedToStream()
772 MoreExecutors.directExecutor(), in noDeadlineShouldBePropagatedToStream()
[all …]
|
| D | SerializingExecutorTest.java | 24 import com.google.common.util.concurrent.MoreExecutors;
188 executor = new SerializingExecutor(MoreExecutors.directExecutor()); in direct()
199 executor = new SerializingExecutor(MoreExecutors.directExecutor()); in testDirectReentrant()
|
| D | ConnectivityStateManagerTest.java | 26 import com.google.common.util.concurrent.MoreExecutors;
224 state.notifyWhenStateChanged(newRecursiveCallback(MoreExecutors.directExecutor()),
225 MoreExecutors.directExecutor(), state.getState());
|
| /external/grpc-grpc-java/context/src/test/java/io/grpc/ |
| D | ContextTest.java | 31 import com.google.common.util.concurrent.MoreExecutors;
137 root.addListener(cancellationListener, MoreExecutors.directExecutor()); in rootCanNeverHaveAListener()
288 base.addListener(new SetContextCancellationListener(observed1), MoreExecutors.directExecutor()); in notifyListenersOnCancel()
290 base.addListener(new SetContextCancellationListener(observed2), MoreExecutors.directExecutor()); in notifyListenersOnCancel()
298 base.addListener(new SetContextCancellationListener(observed3), MoreExecutors.directExecutor()); in notifyListenersOnCancel()
367 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in cascadingCancellationNotifiesChild()
410 attached.addListener(cancellationListener, MoreExecutors.directExecutor()); in cancellableContextIsAttached()
425 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in cancellableContextCascadesFromCancellableParent()
443 fork.addListener(cancellationListener, MoreExecutors.directExecutor()); in nonCascadingCancellationDoesNotNotifyForked()
611 }, MoreExecutors.directExecutor()); in earlierParentDeadlineTakesPrecedenceOverLaterChildDeadline()
[all …]
|
| /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);
|
| /external/opencensus-java/impl_core/src/main/java/io/opencensus/implcore/internal/ |
| D | DaemonThreadFactory.java | 19 import com.google.common.util.concurrent.MoreExecutors;
31 private static final ThreadFactory threadFactory = MoreExecutors.platformThreadFactory();
|
| /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()
|
| /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/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | ConcurrencyTest.java | 20 import com.google.common.util.concurrent.MoreExecutors;
166 MoreExecutors.shutdownAndAwaitTermination(serverExecutor, 5, TimeUnit.SECONDS); in tearDown()
167 MoreExecutors.shutdownAndAwaitTermination(clientExecutor, 5, TimeUnit.SECONDS); in tearDown()
|
| /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()
|
| /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/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceServer.java | 20 import com.google.common.util.concurrent.MoreExecutors;
165 MoreExecutors.shutdownAndAwaitTermination(executor, 5, TimeUnit.SECONDS); in stop()
|
| /external/opencensus-java/exporters/trace/ocagent/src/test/java/io/opencensus/exporter/trace/ocagent/ |
| D | FakeOcAgentTraceServiceGrpcImpl.java | 19 import com.google.common.util.concurrent.MoreExecutors;
135 Executor executor = MoreExecutors.directExecutor(); in startServer()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | KeepAliveManager.java | 23 import com.google.common.util.concurrent.MoreExecutors;
277 }, MoreExecutors.directExecutor()); in ping()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/util/ |
| D | TransmitStatusRuntimeExceptionInterceptor.java | 19 import com.google.common.util.concurrent.MoreExecutors;
125 new SerializingExecutor(MoreExecutors.directExecutor());
|