| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractAbstractFutureTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
150 future.addListener(listener, directExecutor()); in testListenLaterSuccessful()
160 future.addListener(listener, directExecutor()); in testListenLaterFailed()
170 future.addListener(listener, directExecutor()); in testListenLaterCancelled()
180 future.addListener(listener, directExecutor()); in testListenLaterInterrupted()
190 future.addListener(listener, directExecutor()); in testListenLaterSetAsynchronously()
202 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
204 future.addListener(inBetween, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
206 future.addListener(after, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
218 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateFailed()
[all …]
|
| D | ExecutionSequencerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
65 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
68 Future<?> possiblyIgnoredError1 = serializer.submitAsync(secondCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
77 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
79 ListenableFuture<Void> secondFuture = serializer.submitAsync(secondCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
82 Future<?> possiblyIgnoredError1 = serializer.submitAsync(thirdCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
102 directExecutor()); in testCancellationMultipleThreads()
129 directExecutor()); in testSecondTaskWaitsForFirstEvenIfCancelled()
165 directExecutor()); in testCancellationWithReferencedObject()
166 serializer.submit(toStringCallable(toBeGCed), directExecutor()).cancel(true); in testCancellationWithReferencedObject()
[all …]
|
| D | FutureCallbackTest.java | 21 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
41 addCallback(f, callback, directExecutor()); in testSameThreadSuccess()
59 addCallback(f, callback, directExecutor()); in testSameThreadExecutionException()
81 addCallback(f, callback, directExecutor()); in testCancel()
89 addCallback(f, callback, directExecutor()); in testThrowErrorFromGet()
96 addCallback(f, callback, directExecutor()); in testRuntimeExeceptionFromGet()
106 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsRuntimeException()
122 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsError()
146 addCallback(f, callback, directExecutor()); in testWildcardFuture()
|
| D | FuturesTest.java | 46 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
253 ListenableFuture<?> transformedFuture = transform(nullFuture, constant(null), directExecutor());
267 Bar bar = getDone(transform(future, function, directExecutor()));
284 ListenableFuture<Object> unused = transform(root, identity(), directExecutor());
291 output = transform(output, identity(), directExecutor());
313 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
333 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
344 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
356 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
367 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
[all …]
|
| D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
62 directExecutor()); in testExecute_idempotent()
85 directExecutor()); in testExecute_idempotentConcurrently()
125 MoreExecutors.directExecutor()); in testOrdering()
145 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
147 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
|
| D | FluentFutureTest.java | 23 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
73 directExecutor()); in testAddCallback()
88 directExecutor()); in testCatching()
103 directExecutor()); in testCatchingAsync()
117 directExecutor()); in testTransform()
131 directExecutor()); in testTransformAsync()
|
| D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
81 ExecutorSpy spy = new ExecutorSpy(directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
93 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
151 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadCustomExecutorInterrupted()
254 listenable.addListener(earlyListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
262 listenable.addListener(lateListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
54 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch()
69 queue.addListener(listener1, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
76 queue.addListener(listener2, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
87 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withExceptions()
113 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withLabeledExceptions()
|
| D | ServiceManagerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
175 manager.addListener(listener, directExecutor()); in testServiceStartStop()
199 manager.addListener(listener, directExecutor()); in testFailStart()
223 manager.addListener(listener, directExecutor()); in testFailRun()
246 manager.addListener(listener, directExecutor()); in testFailStop()
296 manager.addListener(listener, directExecutor()); in testSingleFailedServiceCallsStopped()
313 manager.addListener(listener, directExecutor()); in testFailStart_singleServiceCallsHealthy()
339 directExecutor()); in testFailStart_stopOthers()
413 manager.addListener(listener, directExecutor()); in testEmptyServiceManager()
482 directExecutor()); in testListenerDeadlock()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractAbstractFutureTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
150 future.addListener(listener, directExecutor()); in testListenLaterSuccessful()
160 future.addListener(listener, directExecutor()); in testListenLaterFailed()
170 future.addListener(listener, directExecutor()); in testListenLaterCancelled()
180 future.addListener(listener, directExecutor()); in testListenLaterInterrupted()
190 future.addListener(listener, directExecutor()); in testListenLaterSetAsynchronously()
202 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
204 future.addListener(inBetween, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
206 future.addListener(after, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateSuccessful()
218 future.addListener(before, directExecutor()); in testListenLaterSetAsynchronouslyLaterDelegateFailed()
[all …]
|
| D | ExecutionSequencerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
65 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
68 Future<?> possiblyIgnoredError1 = serializer.submitAsync(secondCallable, directExecutor()); in testCallableStartsAfterFirstFutureCompletes()
77 Future<?> possiblyIgnoredError = serializer.submitAsync(firstCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
79 ListenableFuture<Void> secondFuture = serializer.submitAsync(secondCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
82 Future<?> possiblyIgnoredError1 = serializer.submitAsync(thirdCallable, directExecutor()); in testCancellationDoesNotViolateSerialization()
102 directExecutor()); in testCancellationMultipleThreads()
129 directExecutor()); in testSecondTaskWaitsForFirstEvenIfCancelled()
165 directExecutor()); in testCancellationWithReferencedObject()
166 serializer.submit(toStringCallable(toBeGCed), directExecutor()).cancel(true); in testCancellationWithReferencedObject()
[all …]
|
| D | FutureCallbackTest.java | 21 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
41 addCallback(f, callback, directExecutor()); in testSameThreadSuccess()
59 addCallback(f, callback, directExecutor()); in testSameThreadExecutionException()
81 addCallback(f, callback, directExecutor()); in testCancel()
89 addCallback(f, callback, directExecutor()); in testThrowErrorFromGet()
96 addCallback(f, callback, directExecutor()); in testRuntimeExeceptionFromGet()
106 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsRuntimeException()
122 addCallback(future, callback, directExecutor()); in testOnSuccessThrowsError()
146 addCallback(f, callback, directExecutor()); in testWildcardFuture()
|
| D | FuturesTest.java | 46 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
253 ListenableFuture<?> transformedFuture = transform(nullFuture, constant(null), directExecutor());
267 Bar bar = getDone(transform(future, function, directExecutor()));
284 ListenableFuture<Object> unused = transform(root, identity(), directExecutor());
291 output = transform(output, identity(), directExecutor());
313 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
333 ListenableFuture<Object> output = transform(input, transformer, directExecutor());
344 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
356 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
367 ListenableFuture<Object> output = transform(input, identity(), directExecutor());
[all …]
|
| D | ExecutionListTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
62 directExecutor()); in testExecute_idempotent()
85 directExecutor()); in testExecute_idempotentConcurrently()
125 MoreExecutors.directExecutor()); in testOrdering()
145 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
147 list.add(THROWING_RUNNABLE, directExecutor()); in testExceptionsCaught()
|
| D | FluentFutureTest.java | 23 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
73 directExecutor()); in testAddCallback()
88 directExecutor()); in testCatching()
103 directExecutor()); in testCatchingAsync()
117 directExecutor()); in testTransform()
131 directExecutor()); in testTransformAsync()
|
| D | JdkFutureAdaptersTest.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
81 ExecutorSpy spy = new ExecutorSpy(directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
93 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
151 listenableFuture.addListener(singleCallListener, directExecutor()); in testListenInPoolThreadCustomExecutorInterrupted()
254 listenable.addListener(earlyListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
262 listenable.addListener(lateListener, directExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
|
| D | ListenerCallQueueTest.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
54 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch()
69 queue.addListener(listener1, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
76 queue.addListener(listener2, directExecutor()); in testEnqueueAndDispatch_multipleListeners()
87 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withExceptions()
113 queue.addListener(listener, directExecutor()); in testEnqueueAndDispatch_withLabeledExceptions()
|
| D | ServiceManagerTest.java | 20 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
175 manager.addListener(listener, directExecutor()); in testServiceStartStop()
199 manager.addListener(listener, directExecutor()); in testFailStart()
223 manager.addListener(listener, directExecutor()); in testFailRun()
246 manager.addListener(listener, directExecutor()); in testFailStop()
296 manager.addListener(listener, directExecutor()); in testSingleFailedServiceCallsStopped()
313 manager.addListener(listener, directExecutor()); in testFailStart_singleServiceCallsHealthy()
339 directExecutor()); in testFailStart_stopOthers()
413 manager.addListener(listener, directExecutor()); in testEmptyServiceManager()
482 directExecutor()); in testListenerDeadlock()
|
| /external/guava/guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/ |
| D | GwtFuturesCatchingSpecialization.java | 17 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
40 return AbstractCatchingFuture.create(input, exceptionType, fallback, directExecutor()); in catching()
57 return AbstractCatchingFuture.create(input, exceptionType, fallback, directExecutor()); in catchingAsync()
|
| /external/opencensus-java/contrib/agent/src/jmh/java/io/opencensus/contrib/agent/instrumentation/ |
| D | ExecutorInstrumentationBenchmark.java | 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/java/dagger/producers/internal/ |
| D | Producers.java | 22 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
55 transform(future, Producers.<T>resultToProduced(), directExecutor()), in createFutureProduced()
58 directExecutor()); in createFutureProduced()
101 directExecutor()); in createFutureSingletonSet() method
120 directExecutor());
|
| D | DependencyMethodProducer.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
67 directExecutor()); in get()
113 directExecutor()); in newEntryPointView()
|
| /external/connectedappssdk/processor/src/main/resources/futurewrappers/ |
| D | ListenableFutureWrapper.java | 18 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
75 directExecutor()); in writeFutureResult()
117 directExecutor()) in groupResults()
118 .addCallback(new MergerFutureCallback<>(result.getKey(), merger), directExecutor()); in groupResults()
|
| /external/connectedappssdk/tests/shared/src/main/java/com/google/android/enterprise/connectedapps/ |
| D | SharedTestUtilities.java | 19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
62 directExecutor()) in assertFutureHasException()
83 directExecutor()) in assertFutureDoesNotHaveException()
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | GrpcServerRule.java | 56 public final GrpcServerRule directExecutor() { in directExecutor() method in GrpcServerRule
130 serverBuilder.directExecutor(); in before()
138 channelBuilder.directExecutor(); in before()
|