HomeSort by relevance Sort by last modified time
    Searched refs:executor (Results 26 - 50 of 91) sorted by null

12 3 4

  /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 ) {

Completed in 638 milliseconds

12 3 4