Home
last modified time | relevance | path

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

/external/chromium_org/net/proxy/
Dmulti_threaded_proxy_resolver.cc28 class MultiThreadedProxyResolver::Executor class in net::MultiThreadedProxyResolver
29 : public base::RefCountedThreadSafe<MultiThreadedProxyResolver::Executor > {
36 Executor(MultiThreadedProxyResolver* coordinator,
58 friend class base::RefCountedThreadSafe<Executor>;
59 ~Executor();
97 void set_executor(Executor* executor) { in set_executor()
104 Executor* executor() { in executor()
160 Executor* executor_;
307 MultiThreadedProxyResolver::Executor::Executor( in Executor() function in net::MultiThreadedProxyResolver::Executor
322 void MultiThreadedProxyResolver::Executor::StartJob(Job* job) { in StartJob()
[all …]
Dmulti_threaded_proxy_resolver.h107 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/
DJdkFutureAdapters.java24 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()
DExecutionList.java23 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()
DAbstractIdleService.java22 import java.util.concurrent.Executor;
86 protected Executor executor(final State state) { in executor()
87 return new Executor() { in executor()
DAbstractExecutionThreadService.java22 import java.util.concurrent.Executor;
122 protected Executor executor() { in executor()
123 return new Executor() { in executor()
DListenableFuture.java19 import java.util.concurrent.Executor;
122 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;
77 public void addListener(Runnable listener, Executor exec) { in addListener()
DFutures.java46 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) {
DAbstractFuture.java23 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/
DAbstractIdleServiceTest.java24 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()
DAbstractExecutionThreadServiceTest.java26 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()
DExecutionListTest.java27 import java.util.concurrent.Executor;
40 protected Executor exec = Executors.newCachedThreadPool();
87 tester.setDefault(Executor.class, sameThreadExecutor()); in testNulls()
DFuturesTest.java55 import java.util.concurrent.Executor;
345 static class ExecutorSpy implements Executor {
346 Executor delegate;
349 public ExecutorSpy(Executor delegate) {
1916 tester.setDefault(Executor.class, MoreExecutors.sameThreadExecutor());
/external/guava/guava/src/com/google/common/eventbus/
DAsyncEventBus.java21 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/guava/guava/src/com/google/common/cache/
DRemovalListeners.java21 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/
DAsyncEventBusTest.java21 import java.util.concurrent.Executor;
70 public static class FakeExecutor implements Executor {
/external/deqp/executor/
DCMakeLists.txt1 # Executor
3 # Executor depends on execserver library (xscore)
/external/guava/guava-bootstrap/src/java/util/concurrent/
DExecutorService.java16 public interface ExecutorService extends Executor {
/external/javassist/src/main/javassist/bytecode/analysis/
DAnalyzer.java138 Executor executor = new Executor(clazz.getClassPool(), method.getConstPool()); in analyze()
168 IntQueue queue, Executor executor) throws BadBytecode { in analyzeNextEntry()
DExecutor.java32 public class Executor implements Opcode { class
40 public Executor(ClassPool classPool, ConstPool constPool) { in Executor() method in Executor
/external/chromium_org/sync/test/android/javatests/src/org/chromium/sync/test/util/
DMockAccountManager.java39 import java.util.concurrent.Executor;
376 private static <T> AccountManagerFuture<T> runTask(Executor executorService,
/external/qemu/distrib/sdl-1.2.15/
DCREDITS6 -- Executor rocks! *grin*
/external/deqp/
DCMakeLists.txt204 # Executor framework and tools