| /external/chromium_org/net/proxy/ |
| D | multi_threaded_proxy_resolver.cc | 27 class MultiThreadedProxyResolver::Executor class in net::MultiThreadedProxyResolver
28 : public base::RefCountedThreadSafe<MultiThreadedProxyResolver::Executor > {
35 Executor(MultiThreadedProxyResolver* coordinator,
57 friend class base::RefCountedThreadSafe<Executor>;
58 ~Executor();
96 void set_executor(Executor* executor) { in set_executor()
103 Executor* executor() { in executor()
159 Executor* executor_;
285 MultiThreadedProxyResolver::Executor::Executor( in Executor() function in net::MultiThreadedProxyResolver::Executor
300 void MultiThreadedProxyResolver::Executor::StartJob(Job* job) { in StartJob()
[all …]
|
| D | multi_threaded_proxy_resolver.h | 107 class Executor;
114 typedef std::vector<scoped_refptr<Executor> > ExecutorList;
125 Executor* FindIdleExecutor();
128 Executor* AddNewExecutor();
131 void OnExecutorReady(Executor* executor);
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | JdkFutureAdapters.java | 24 import java.util.concurrent.Executor;
68 Future<V> future, Executor executor) { in listenInPoolThread()
94 private static final Executor defaultAdapterExecutor =
97 private final Executor adapterExecutor;
113 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
124 public void addListener(Runnable listener, Executor exec) { in addListener()
|
| D | ExecutionList.java | 23 import java.util.concurrent.Executor;
80 public void add(Runnable runnable, Executor executor) { in add()
140 final Executor executor;
142 RunnableExecutorPair(Runnable runnable, Executor executor) { in RunnableExecutorPair()
|
| D | AbstractIdleService.java | 22 import java.util.concurrent.Executor;
86 protected Executor executor(final State state) { in executor()
87 return new Executor() { in executor()
|
| D | AbstractExecutionThreadService.java | 22 import java.util.concurrent.Executor;
122 protected Executor executor() { in executor()
123 return new Executor() { in executor()
|
| D | ListenableFuture.java | 19 import java.util.concurrent.Executor;
122 void addListener(Runnable listener, Executor executor); in addListener()
|
| D | ForwardingListenableFuture.java | 21 import java.util.concurrent.Executor;
46 public void addListener(Runnable listener, Executor exec) { in addListener()
|
| D | ListenableFutureTask.java | 20 import java.util.concurrent.Executor;
77 public void addListener(Runnable listener, Executor exec) { in addListener()
|
| D | Futures.java | 46 import java.util.concurrent.Executor;
268 Executor executor) {
390 Executor executor) {
498 final Function<? super I, ? extends O> function, Executor executor) {
966 final FutureCallback<? super V> callback, Executor executor) {
1293 final boolean allMustSucceed, final Executor listenerExecutor) {
1302 private void init(final Executor listenerExecutor) {
|
| D | AbstractFuture.java | 23 import java.util.concurrent.Executor;
154 public void addListener(Runnable listener, Executor exec) { in addListener()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractIdleServiceTest.java | 24 import java.util.concurrent.Executor;
36 private final Executor executor = new Executor() {
78 @Override protected Executor executor(Service.State state) { in testTimeout()
79 return new Executor() { in testTimeout()
113 @Override protected Executor executor(Service.State state) { in executor()
|
| D | AbstractExecutionThreadServiceTest.java | 26 import java.util.concurrent.Executor;
43 private final Executor executor = new Executor() {
163 @Override protected Executor executor() { in executor()
198 @Override protected Executor executor() { in executor()
241 @Override protected Executor executor() { in executor()
273 @Override protected Executor executor() { in executor()
290 @Override protected Executor executor() { in executor()
291 return new Executor() { in executor()
|
| D | ExecutionListTest.java | 27 import java.util.concurrent.Executor;
40 protected Executor exec = Executors.newCachedThreadPool();
87 tester.setDefault(Executor.class, sameThreadExecutor()); in testNulls()
|
| /external/chromium_org/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
| D | ExecutorFactory.java | 19 import java.util.concurrent.Executor;
41 private static class PipedExecutor implements Executor, Callback {
171 private static final ThreadLocal<Executor> EXECUTORS = new ThreadLocal<Executor>();
176 public static Executor getExecutorForCurrentThread(Core core) { in getExecutorForCurrentThread()
177 Executor executor = EXECUTORS.get(); in getExecutorForCurrentThread()
|
| D | AutoCloseableRouter.java | 10 import java.util.concurrent.Executor;
25 private final Executor mExecutor;
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 21 import java.util.concurrent.Executor;
32 private final Executor executor;
47 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
60 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
| /external/chromium_org/components/cronet/android/java/src/org/chromium/net/ |
| D | UrlRequestFactory.java | 7 import java.util.concurrent.Executor;
25 UrlRequestListener listener, Executor executor); in createRequest()
|
| D | CronetUrlRequestFactory.java | 7 import java.util.concurrent.Executor;
15 Executor executor) { in createRequest()
|
| /external/guava/guava/src/com/google/common/cache/ |
| D | RemovalListeners.java | 21 import java.util.concurrent.Executor;
43 final RemovalListener<K, V> listener, final Executor executor) { in asynchronous()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | AsyncEventBusTest.java | 21 import java.util.concurrent.Executor;
70 public static class FakeExecutor implements Executor {
|
| /external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/bindings/ |
| D | ExecutorFactoryTest.java | 16 import java.util.concurrent.Executor;
29 private Executor mExecutor;
|
| /external/deqp/executor/ |
| D | CMakeLists.txt | 1 # Executor
3 # Executor depends on execserver library (xscore)
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | ExecutorService.java | 16 public interface ExecutorService extends Executor {
|
| /external/javassist/src/main/javassist/bytecode/analysis/ |
| D | Analyzer.java | 138 Executor executor = new Executor(clazz.getClassPool(), method.getConstPool()); in analyze()
168 IntQueue queue, Executor executor) throws BadBytecode { in analyzeNextEntry()
|