Home
last modified time | relevance | path

Searched refs:sameThreadExecutor (Results 1 – 9 of 9) sorted by relevance

/external/guava/guava-tests/test/com/google/common/util/concurrent/
DExecutionListTest.java19 import static com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor;
80 list.add(THROWING_RUNNABLE, sameThreadExecutor()); in testExceptionsCaught()
82 list.add(THROWING_RUNNABLE, sameThreadExecutor()); in testExceptionsCaught()
87 tester.setDefault(Executor.class, sameThreadExecutor()); in testNulls()
DJdkFutureAdaptersTest.java22 import static com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor;
57 ExecutorSpy spy = new ExecutorSpy(sameThreadExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
70 listenableFuture.addListener(singleCallListener, sameThreadExecutor()); in testListenInPoolThreadIgnoresExecutorWhenDelegateIsDone()
197 listenable.addListener(earlyListener, sameThreadExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
205 listenable.addListener(lateListener, sameThreadExecutor()); in testListenInPoolThreadRunsListenerAfterRuntimeException()
DMoreExecutorsTest.java21 import static com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor;
50 MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceInThreadExecution()
96 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorInvokeAll()
127 final ExecutorService executor = MoreExecutors.sameThreadExecutor(); in testSameThreadExecutorServiceTermination()
207 listeningDecorator(MoreExecutors.sameThreadExecutor()); in testListeningDecorator()
227 future.addListener(listener, sameThreadExecutor()); in assertListenerRunImmediately()
DFuturesTest.java361 ExecutorSpy spy = new ExecutorSpy(MoreExecutors.sameThreadExecutor());
548 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
570 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
581 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
594 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
645 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
704 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
1116 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
1138 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
1149 compound.addListener(listener, MoreExecutors.sameThreadExecutor());
[all …]
DListenableFutureTaskTest.java67 }, MoreExecutors.sameThreadExecutor()); in setUp()
/external/guava/guava/src/com/google/common/util/concurrent/
DFutures.java22 import static com.google.common.util.concurrent.MoreExecutors.sameThreadExecutor;
212 return chain(input, function, MoreExecutors.sameThreadExecutor());
336 return transform(input, function, MoreExecutors.sameThreadExecutor());
446 return transform(future, function, MoreExecutors.sameThreadExecutor());
764 }, MoreExecutors.sameThreadExecutor());
805 MoreExecutors.sameThreadExecutor());
828 MoreExecutors.sameThreadExecutor());
848 MoreExecutors.sameThreadExecutor());
868 MoreExecutors.sameThreadExecutor());
915 addCallback(future, callback, MoreExecutors.sameThreadExecutor());
[all …]
DMoreExecutors.java223 public static ListeningExecutorService sameThreadExecutor() { in sameThreadExecutor() method in MoreExecutors
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DMockFutureListener.java45 future.addListener(this, MoreExecutors.sameThreadExecutor()); in MockFutureListener()
/external/guava/guava/src/com/google/common/cache/
DLocalCache.java155 static final ListeningExecutorService sameThreadExecutor = MoreExecutors.sameThreadExecutor(); field in LocalCache
2370 }, sameThreadExecutor); in loadAsync()