HomeSort by relevance Sort by last modified time
    Searched refs:ThreadPoolExecutor (Results 1 - 25 of 57) sorted by null

1 2 3

  /libcore/luni/src/main/java/java/util/concurrent/
RejectedExecutionHandler.java 10 * A handler for tasks that cannot be executed by a {@link ThreadPoolExecutor}.
18 * Method that may be invoked by a {@link ThreadPoolExecutor} when
19 * {@link ThreadPoolExecutor#execute execute} cannot accept a
32 void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
Executors.java 61 return new ThreadPoolExecutor(nThreads, nThreads,
124 return new ThreadPoolExecutor(nThreads, nThreads,
145 (new ThreadPoolExecutor(1, 1,
166 (new ThreadPoolExecutor(1, 1,
184 * may be created using {@link ThreadPoolExecutor} constructors.
189 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
204 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
ThreadPoolExecutor.java 28 * Each {@code ThreadPoolExecutor} also maintains some basic
47 * <dd>A {@code ThreadPoolExecutor} will automatically adjust the
176 * RejectedExecutionHandler#rejectedExecution(Runnable, ThreadPoolExecutor)}
182 * <li> In the default {@link ThreadPoolExecutor.AbortPolicy}, the
186 * <li> In {@link ThreadPoolExecutor.CallerRunsPolicy}, the thread
191 * <li> In {@link ThreadPoolExecutor.DiscardPolicy}, a task that
194 * <li>In {@link ThreadPoolExecutor.DiscardOldestPolicy}, if the
247 * class PausableThreadPoolExecutor extends ThreadPoolExecutor {
289 public class ThreadPoolExecutor extends AbstractExecutorService {
    [all...]
  /frameworks/testing/espresso/espresso-lib/src/main/java/com/google/android/apps/common/testing/ui/espresso/base/
ThreadPoolExecutorExtractor.java 30 import java.util.concurrent.ThreadPoolExecutor;
57 public ThreadPoolExecutor getAsyncTaskThreadPool() {
58 FutureTask<Optional<ThreadPoolExecutor>> getTask = null;
60 getTask = new FutureTask<Optional<ThreadPoolExecutor>>(LEGACY_ASYNC_TASK_EXECUTOR);
62 getTask = new FutureTask<Optional<ThreadPoolExecutor>>(POST_HONEYCOMB_ASYNC_TASK_EXECUTOR);
74 public Optional<ThreadPoolExecutor> getCompatAsyncTaskThreadPool() {
77 new FutureTask<Optional<ThreadPoolExecutor>>(MODERN_ASYNC_TASK_EXTRACTOR)).get();
112 private static final Callable<Optional<ThreadPoolExecutor>> MODERN_ASYNC_TASK_EXTRACTOR =
113 new Callable<Optional<ThreadPoolExecutor>>() {
115 public Optional<ThreadPoolExecutor> call() throws Exception
    [all...]
AsyncTaskPoolMonitor.java 24 import java.util.concurrent.ThreadPoolExecutor;
32 * This class is based on the assumption that we can get at the ThreadPoolExecutor AsyncTask uses.
39 private final ThreadPoolExecutor pool;
42 AsyncTaskPoolMonitor(ThreadPoolExecutor pool) {
BaseLayerModule.java 38 import java.util.concurrent.ThreadPoolExecutor;
78 Optional<ThreadPoolExecutor> compatThreadPool = extractor.getCompatAsyncTaskThreadPool();
  /libcore/jsr166-tests/src/test/java/jsr166/
ThreadPoolExecutorTest.java 19 static class ExtendedTPE extends ThreadPoolExecutor {
60 final ThreadPoolExecutor p =
61 new ThreadPoolExecutor(1, 1,
82 final ThreadPoolExecutor p =
83 new ThreadPoolExecutor(2, 2,
108 final ThreadPoolExecutor p =
109 new ThreadPoolExecutor(2, 2,
126 final ThreadPoolExecutor p =
127 new ThreadPoolExecutor(2, 2,
143 final ThreadPoolExecutor p
    [all...]
ThreadPoolExecutorSubclassTest.java 114 static class CustomTPE extends ThreadPoolExecutor {
200 final ThreadPoolExecutor p =
222 final ThreadPoolExecutor p =
248 ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
263 ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
277 final ThreadPoolExecutor p =
312 ThreadPoolExecutor p = new CustomTPE(1, 1, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
321 ThreadPoolExecutor p = new CustomTPE(2, 2, 1000, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
331 ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10), tf, new NoOpREHandler());
340 ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10))
    [all...]
  /external/okhttp/benchmarks/src/main/java/com/squareup/okhttp/benchmarks/
SynchronousHttpClient.java 22 import java.util.concurrent.ThreadPoolExecutor;
27 ThreadPoolExecutor executor;
32 executor = new ThreadPoolExecutor(benchmark.concurrencyLevel, benchmark.concurrencyLevel,
OkHttpAsync.java 27 import java.util.concurrent.ThreadPoolExecutor;
51 client.setDispatcher(new Dispatcher(new ThreadPoolExecutor(benchmark.concurrencyLevel,
  /development/samples/WiFiDirectServiceDiscovery/src/com/example/android/wifidirect/discovery/
GroupOwnerSocketHandler.java 10 import java.util.concurrent.ThreadPoolExecutor;
40 private final ThreadPoolExecutor pool = new ThreadPoolExecutor(
  /cts/libs/vogar-expect/src/vogar/util/
Threads.java 22 import java.util.concurrent.ThreadPoolExecutor;
49 return new ThreadPoolExecutor(count, count, 10, TimeUnit.SECONDS,
  /development/samples/training/threadsample/src/com/example/android/threadsample/
PhotoManager.java 29 import java.util.concurrent.ThreadPoolExecutor;
101 private final ThreadPoolExecutor mDownloadThreadPool;
104 private final ThreadPoolExecutor mDecodeThreadPool;
147 mDownloadThreadPool = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE,
153 mDecodeThreadPool = new ThreadPoolExecutor(NUMBER_OF_CORES, NUMBER_OF_CORES,
  /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
FifoPriorityThreadPoolExecutor.java 7 import java.util.concurrent.ThreadPoolExecutor;
12 * A FIFO priority {@link ThreadPoolExecutor} that prioritizes submitted {@link Runnable}s by assuming they implement
17 public class FifoPriorityThreadPoolExecutor extends ThreadPoolExecutor {
  /cts/tests/tests/hardware/src/android/hardware/cts/helpers/sensoroperations/
ParallelSensorOperation.java 31 import java.util.concurrent.ThreadPoolExecutor;
86 ThreadPoolExecutor executor = new ThreadPoolExecutor(
  /external/owasp/sanitizer/src/tests/org/owasp/html/
HtmlSanitizerFuzzerTest.java 33 import java.util.concurrent.ThreadPoolExecutor;
75 ThreadPoolExecutor executor = new ThreadPoolExecutor(
  /frameworks/testing/espresso/espresso-lib-tests/src/androidTest/java/com/google/android/apps/common/testing/ui/espresso/base/
AsyncTaskPoolMonitorTest.java 25 import java.util.concurrent.ThreadPoolExecutor;
34 private final ThreadPoolExecutor testThreadPool = new ThreadPoolExecutor(
  /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/
DictionaryService.java 32 import java.util.concurrent.ThreadPoolExecutor;
96 private ThreadPoolExecutor mExecutor;
107 // Executors#newSingleThreadExecutor creates a ThreadPoolExecutor but it returns the
110 mExecutor = new ThreadPoolExecutor(1 /* corePoolSize */, 1 /* maximumPoolSize */,
  /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/
Dispatcher.java 24 import java.util.concurrent.ThreadPoolExecutor;
56 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
  /packages/apps/Mms/src/com/android/mms/util/
BackgroundLoaderManager.java 28 import java.util.concurrent.ThreadPoolExecutor;
74 mExecutor = new ThreadPoolExecutor(
  /external/guava/guava/src/com/google/common/util/concurrent/
MoreExecutors.java 33 import java.util.concurrent.ThreadPoolExecutor;
34 import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
53 * Converts the given ThreadPoolExecutor into an ExecutorService that exits
69 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
149 * Converts the given ThreadPoolExecutor into an ExecutorService that exits
165 ThreadPoolExecutor executor) {
170 * Converts the given ThreadPoolExecutor into a ScheduledExecutorService that
  /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/util/
ThreadPool.java 23 import java.util.concurrent.ThreadPoolExecutor;
88 mExecutor = new ThreadPoolExecutor(
  /developers/build/prebuilts/gradle/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/
AsyncTask.java 34 import java.util.concurrent.ThreadPoolExecutor;
64 * {@link java.util.concurrent.ThreadPoolExecutor} and {@link java.util.concurrent.FutureTask}.</p>
219 = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
221 new ThreadPoolExecutor.DiscardOldestPolicy());
  /developers/samples/android/ui/graphics/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/
AsyncTask.java 34 import java.util.concurrent.ThreadPoolExecutor;
64 * {@link java.util.concurrent.ThreadPoolExecutor} and {@link java.util.concurrent.FutureTask}.</p>
219 = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
221 new ThreadPoolExecutor.DiscardOldestPolicy());
  /development/samples/browseable/DisplayingBitmaps/src/com.example.android.displayingbitmaps/util/
AsyncTask.java 34 import java.util.concurrent.ThreadPoolExecutor;
64 * {@link java.util.concurrent.ThreadPoolExecutor} and {@link java.util.concurrent.FutureTask}.</p>
219 = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
221 new ThreadPoolExecutor.DiscardOldestPolicy());

Completed in 860 milliseconds

1 2 3