Home
last modified time | relevance | path

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

1234567

/external/guava/android/guava-tests/test/com/google/common/util/concurrent/
DAbstractAbstractFutureTest.java22 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 …]
DExecutionSequencerTest.java20 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 …]
DFutureCallbackTest.java21 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()
DFuturesTest.java46 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 …]
DExecutionListTest.java19 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()
DFluentFutureTest.java23 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()
DJdkFutureAdaptersTest.java22 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()
DListenerCallQueueTest.java19 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()
DServiceManagerTest.java20 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/
DAbstractAbstractFutureTest.java22 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 …]
DExecutionSequencerTest.java20 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 …]
DFutureCallbackTest.java21 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()
DFuturesTest.java46 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 …]
DExecutionListTest.java19 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()
DFluentFutureTest.java23 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()
DJdkFutureAdaptersTest.java22 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()
DListenerCallQueueTest.java19 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()
DServiceManagerTest.java20 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/
DGwtFuturesCatchingSpecialization.java17 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/
DExecutorInstrumentationBenchmark.java56 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/
DProducers.java22 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());
DDependencyMethodProducer.java19 import static com.google.common.util.concurrent.MoreExecutors.directExecutor;
67 directExecutor()); in get()
113 directExecutor()); in newEntryPointView()
/external/connectedappssdk/processor/src/main/resources/futurewrappers/
DListenableFutureWrapper.java18 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/
DSharedTestUtilities.java19 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/
DGrpcServerRule.java56 public final GrpcServerRule directExecutor() { in directExecutor() method in GrpcServerRule
130 serverBuilder.directExecutor(); in before()
138 channelBuilder.directExecutor(); in before()

1234567