/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());
|