/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/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-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()
|