Home
last modified time | relevance | path

Searched refs:Executor (Results 1 – 25 of 86) sorted by relevance

1234

/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DExecutionListBenchmark.java33 import java.util.concurrent.Executor;
53 void add(Runnable runnable, Executor executor); in add()
64 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
82 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
100 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList()
118 @Override public void add(Runnable runnable, Executor executor) {
136 @Override public void add(Runnable runnable, Executor executor) {
186 @Footprint(exclude = {Runnable.class, Executor.class})
281 public void add(Runnable runnable, Executor executor) {
315 final Executor executor;
[all …]
DMoreExecutorsDirectExecutorBenchmark.java31 import java.util.concurrent.Executor;
42 @Override Executor executor() { in executor()
47 @Override Executor executor() { in executor()
51 abstract Executor executor(); in executor()
55 Executor executor;
96 final Executor executor = this.executor; in timeUncontendedExecute()
105 final Executor executor = this.executor; in timeContendedExecute()
DFuturesCombineBenchmark.java29 import java.util.concurrent.Executor;
39 @Override <V> ListenableFuture<V> combine(final Callable<V> combiner, Executor executor, in combine()
59 <V> ListenableFuture<V> combine(Callable<V> combiner, final Executor executor,
66 Callable<V> combiner, Executor executor,
70 private static final Executor INLINE_EXECUTOR = new Executor() {
/external/guava/guava/src/com/google/common/util/concurrent/
DJdkFutureAdapters.java24 import java.util.concurrent.Executor;
91 Future<V> future, Executor executor) { in listenInPoolThread()
117 private static final Executor defaultAdapterExecutor =
120 private final Executor adapterExecutor;
136 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
147 public void addListener(Runnable listener, Executor exec) { in addListener()
DExecutionList.java22 import java.util.concurrent.Executor;
81 public void add(Runnable runnable, Executor executor) { in add()
154 private static void executeListener(Runnable runnable, Executor executor) { in executeListener()
168 final Executor executor;
171 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair()
DAbstractExecutionThreadService.java23 import java.util.concurrent.Executor;
46 Executor executor = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() {
142 protected Executor executor() { in executor()
143 return new Executor() { in executor()
166 @Override public final void addListener(Listener listener, Executor executor) {
DSerializingExecutor.java23 import java.util.concurrent.Executor;
46 final class SerializingExecutor implements Executor {
51 private final Executor executor;
76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
DAbstractIdleService.java23 import java.util.concurrent.Executor;
97 protected Executor executor() { in executor()
98 return new Executor() { in executor()
120 @Override public final void addListener(Listener listener, Executor executor) {
DListenerCallQueue.java25 import java.util.concurrent.Executor;
60 private final Executor executor;
65 ListenerCallQueue(L listener, Executor executor) { in ListenerCallQueue()
DListenableFuture.java19 import java.util.concurrent.Executor;
134 void addListener(Runnable listener, Executor executor); in addListener()
DForwardingListenableFuture.java21 import java.util.concurrent.Executor;
46 public void addListener(Runnable listener, Executor exec) { in addListener()
DListenableFutureTask.java20 import java.util.concurrent.Executor;
82 public void addListener(Runnable listener, Executor exec) { in addListener()
DService.java21 import java.util.concurrent.Executor;
171 void addListener(Listener listener, Executor executor); in addListener()
/external/guava/guava/src/com/google/common/eventbus/
DAsyncEventBus.java24 import java.util.concurrent.Executor;
35 private final Executor executor;
50 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
66 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
79 public AsyncEventBus(Executor executor) { in AsyncEventBus()
/external/libmojo/mojo/public/java/bindings/src/org/chromium/mojo/bindings/
DExecutorFactory.java20 import java.util.concurrent.Executor;
42 private static class PipedExecutor implements Executor, Callback {
172 private static final ThreadLocal<Executor> EXECUTORS = new ThreadLocal<Executor>();
177 public static Executor getExecutorForCurrentThread(Core core) { in getExecutorForCurrentThread()
178 Executor executor = EXECUTORS.get(); in getExecutorForCurrentThread()
DAutoCloseableRouter.java10 import java.util.concurrent.Executor;
25 private final Executor mExecutor;
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractExecutionThreadServiceTest.java26 import java.util.concurrent.Executor;
45 private final Executor exceptionCatchingExecutor = new Executor() {
158 @Override protected Executor executor() { in executor()
193 @Override protected Executor executor() { in executor()
247 @Override protected Executor executor() { in executor()
279 @Override protected Executor executor() { in executor()
296 @Override protected Executor executor() { in executor()
297 return new Executor() { in executor()
375 @Override protected Executor executor() { in executor()
DAbstractIdleServiceTest.java27 import java.util.concurrent.Executor;
178 @Override protected Executor executor() { in testTimeout()
179 return new Executor() { in testTimeout()
211 @Override protected Executor executor() { in executor()
/external/volley/src/main/java/com/android/volley/
DExecutorDelivery.java21 import java.util.concurrent.Executor;
28 private final Executor mResponsePoster;
36 mResponsePoster = new Executor() { in ExecutorDelivery()
49 public ExecutorDelivery(Executor executor) { in ExecutorDelivery()
/external/libcxx/utils/libcxx/test/
Dexecutor.py17 class Executor(object): class
34 class LocalExecutor(Executor):
72 class PrefixExecutor(Executor):
90 class PostfixExecutor(Executor):
115 class RemoteExecutor(Executor):
/external/volley/src/test/java/com/android/volley/utils/
DImmediateResponseDelivery.java21 import java.util.concurrent.Executor;
30 super(new Executor() { in ImmediateResponseDelivery()
/external/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/
DTestComponentWithBuilder.java20 import java.util.concurrent.Executor;
34 Builder executor(Executor executor); in executor()
/external/guava/guava/src/com/google/common/cache/
DRemovalListeners.java23 import java.util.concurrent.Executor;
45 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous()
/external/guava/guava-tests/test/com/google/common/eventbus/
DAsyncEventBusTest.java24 import java.util.concurrent.Executor;
72 public static class FakeExecutor implements Executor {
/external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/util/
DLooperExecutor.java17 import java.util.concurrent.Executor;
22 public class LooperExecutor extends Thread implements Executor {

1234