/packages/apps/Contacts/src/com/android/contacts/util/ |
AsyncTaskExecutors.java | 25 import java.util.concurrent.Executor; 87 private final Executor mExecutor; 89 public SimpleAsyncTaskExecutor(Executor executor) { 90 mExecutor = executor;
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
BatchingNamedTaskExecutor.java | 42 * @param executor A SourceTaskExecutor for actually executing the tasks. 44 public BatchingNamedTaskExecutor(NamedTaskExecutor executor) { 45 mExecutor = executor; 61 * Instructs the executor to submit the next batch of results. 80 * Cancel any unstarted tasks running in this executor. This instance
|
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
PackageIconLoaderTest.java | 54 NamedTaskExecutor executor = new SingleThreadNamedTaskExecutor( local 57 executor);
|
/packages/providers/CalendarProvider/src/com/android/providers/calendar/ |
CalendarReceiver.java | 40 private final ExecutorService executor = Executors.newCachedThreadPool(); field in class:CalendarReceiver 55 executor.submit(new Runnable() {
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
SimpleTimeLimiter.java | 50 private final ExecutorService executor; field in class:SimpleTimeLimiter 53 * Constructs a TimeLimiter instance using the given executor service to 56 * <b>Warning:</b> using a bounded executor 62 * @param executor the ExecutorService that will execute the method calls on 66 public SimpleTimeLimiter(ExecutorService executor) { 67 this.executor = checkNotNull(executor); 74 * <p><b>Warning:</b> using a bounded executor may be counterproductive! If 126 Future<T> future = executor.submit(callable);
|
JdkFutureAdapters.java | 24 import java.util.concurrent.Executor; 68 Future<V> future, Executor executor) { 69 checkNotNull(executor); 73 return new ListenableFutureAdapter<V>(future, executor); 94 private static final Executor defaultAdapterExecutor = 97 private final Executor adapterExecutor; 113 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { 124 public void addListener(Runnable listener, Executor exec) {
|
AbstractExecutionThreadService.java | 22 import java.util.concurrent.Executor; 43 executor().execute(new Runnable() { 112 * Returns the {@link Executor} that will be used to run this service. 113 * Subclasses may override this method to use a custom {@link Executor}, which 115 * priority. The returned executor's {@link Executor#execute(Runnable) 119 * <p>The default implementation returns a new {@link Executor} that sets the 122 protected Executor executor() { method in class:AbstractExecutionThreadService 123 return new Executor() { [all...] |
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
AbstractFutureTest.java | 94 ExecutorService executor = Executors.newFixedThreadPool(10); local 98 executor.execute(new Runnable() { 107 executor.execute(new Runnable() { 116 executor.execute(new Runnable() { 133 executor.shutdown();
|
AbstractScheduledServiceTest.java | 51 final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { field in class:AbstractScheduledServiceTest 72 @Override protected ScheduledExecutorService executor() { return executor; } method in class:AbstractScheduledServiceTest.NullService 219 protected ScheduledExecutorService executor() { method in class:AbstractScheduledServiceTest.TestService 221 return executor; 367 @Override protected ScheduledExecutorService executor() { method in class:AbstractScheduledServiceTest.SchedulerTest.TestAbstractScheduledCustomService 413 @Override protected ScheduledExecutorService executor() { method in class:TestFailingCustomScheduledService
|
SimpleTimeLimiterTest.java | 39 private static final ExecutorService executor field in class:SimpleTimeLimiterTest 55 service = new SimpleTimeLimiter(executor);
|
/external/jmdns/src/javax/jmdns/impl/ |
JmmDNSImpl.java | 88 ExecutorService executor = Executors.newCachedThreadPool(); local 90 executor.submit(new Runnable() { 104 executor.shutdown(); 106 executor.awaitTermination(DNSConstants.CLOSE_TIMEOUT, TimeUnit.MILLISECONDS); 201 ExecutorService executor = Executors.newCachedThreadPool(); local 203 executor.submit(new Runnable() { 213 executor.shutdown(); 215 executor.awaitTermination(timeout, TimeUnit.MILLISECONDS); 404 ExecutorService executor = Executors.newCachedThreadPool(); local 406 executor.submit(new Runnable() [all...] |
/libcore/luni/src/test/java/libcore/java/lang/ref/ |
ReferenceQueueTest.java | 93 ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1); local 94 executor.schedule(runnable, delayMillis, TimeUnit.MILLISECONDS); 95 executor.shutdown();
|
/libcore/luni/src/test/java/libcore/java/util/zip/ |
DeflaterOutputStreamTest.java | 69 ExecutorService executor = Executors.newSingleThreadExecutor(); local 73 executor.submit(new Callable<Void>() { 83 executor.shutdown();
|
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
OutputStreamTesterTest.java | 115 private ExecutorService executor; field in class:OutputStreamTesterTest.PipedOutputStreamSinkTester 122 executor = Executors.newSingleThreadExecutor(); 123 future = executor.submit(new Callable<byte[]>() { 139 executor.shutdown();
|
WriterTesterTest.java | 104 private ExecutorService executor; field in class:WriterTesterTest.PipedWriterCharSinkTester 111 executor = Executors.newSingleThreadExecutor(); 112 future = executor.submit(new Callable<char[]>() { 128 executor.shutdown();
|
/external/jmonkeyengine/engine/src/core/com/jme3/asset/ |
ThreadingManager.java | 48 protected final ExecutorService executor = field in class:ThreadingManager 91 // return executor.submit(new MultiLoadingTask(names)); 95 // return executor.submit(new LoadingTask(name));
|
/frameworks/ex/variablespeed/src/com/android/ex/variablespeed/ |
VariableSpeed.java | 28 import java.util.concurrent.Executor; 52 private final Executor mExecutor; 69 private VariableSpeed(Executor executor) throws UnsupportedOperationException { 70 Preconditions.checkNotNull(executor); 71 mExecutor = executor; 82 public static MediaPlayerProxy createVariableSpeed(Executor executor) 84 return new SingleThreadedMediaPlayerProxy(new VariableSpeed(executor));
|
/external/okhttp/src/test/java/libcore/net/spdy/ |
MockSpdyPeer.java | 29 import java.util.concurrent.Executor; 42 private final Executor executor = Executors.newCachedThreadPool( field in class:MockSpdyPeer 67 executor.execute(new Runnable() {
|
/external/sqlite/android/ |
PhoneticStringUtilsTest.cpp | 211 TestExecutor executor; local 212 if(executor.DoAllTests()) {
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
SourceShortcutRefresher.java | 41 * Create a ShortcutRefresher that will refresh shortcuts using the given executor. 43 * @param executor Used to execute the tasks. 45 public SourceShortcutRefresher(NamedTaskExecutor executor) { 46 mExecutor = executor;
|
MultiSourceCorpus.java | 27 import java.util.concurrent.Executor; 34 private final Executor mExecutor; 46 Executor executor, Source... sources) { 48 mExecutor = executor;
|
SearchableCorpusFactory.java | 27 import java.util.concurrent.Executor; 42 private final Factory<Executor> mWebCorpusExecutorFactory; 45 Factory<Executor> webCorpusExecutorFactory) { 67 protected Executor createWebCorpusExecutor() { 119 Executor executor = createWebCorpusExecutor(); local 120 return new WebCorpus(mContext, mConfig, mSettings, executor, webSource, browserSource);
|
/external/chromium/net/proxy/ |
multi_threaded_proxy_resolver.h | 106 class Executor; 113 typedef std::vector<scoped_refptr<Executor> > ExecutorList; 124 Executor* FindIdleExecutor(); 127 Executor* AddNewExecutor(); 130 void OnExecutorReady(Executor* executor);
|
/packages/apps/Email/emailcommon/src/com/android/emailcommon/utility/ |
EmailAsyncTask.java | 24 import java.util.concurrent.Executor; 40 private static final Executor SERIAL_EXECUTOR = AsyncTask.SERIAL_EXECUTOR; 41 private static final Executor PARALLEL_EXECUTOR = AsyncTask.THREAD_POOL_EXECUTOR; 215 private final EmailAsyncTask<Params, Progress, Result> executeInternal(Executor executor, 224 mInnerTask.executeOnExecutor(executor, params); 242 private static EmailAsyncTask<Void, Void, Void> runAsyncInternal(Executor executor, 251 return task.executeInternal(executor, false, (Void[]) null);
|
/external/antlr/antlr-3.4/gunit-maven-plugin/src/main/java/org/antlr/mojo/antlr3/ |
GUnitExecuteMojo.java | 299 gUnitExecutor executor = new gUnitExecutor( local 305 String report = executor.execTest(); 309 testResult.tests = executor.numOfTest; 310 testResult.failures = executor.numOfFailure; 311 testResult.invalids = executor.numOfInvalidInput; 316 for ( AbstractTest test : executor.failures ) {
|