| /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 | 62 return new ThreadPoolExecutor(nThreads, nThreads,
125 return new ThreadPoolExecutor(nThreads, nThreads,
146 (new ThreadPoolExecutor(1, 1,
167 (new ThreadPoolExecutor(1, 1,
185 * may be created using {@link ThreadPoolExecutor} constructors.
190 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
205 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
|
| ThreadPoolExecutor.java | 29 * Each {@code ThreadPoolExecutor} also maintains some basic
48 * <dd>A {@code ThreadPoolExecutor} will automatically adjust the
177 * RejectedExecutionHandler#rejectedExecution(Runnable, ThreadPoolExecutor)}
183 * <li> In the default {@link ThreadPoolExecutor.AbortPolicy}, the
187 * <li> In {@link ThreadPoolExecutor.CallerRunsPolicy}, the thread
192 * <li> In {@link ThreadPoolExecutor.DiscardPolicy}, a task that
195 * <li>In {@link ThreadPoolExecutor.DiscardOldestPolicy}, if the
248 * class PausableThreadPoolExecutor extends ThreadPoolExecutor {
290 public class ThreadPoolExecutor extends AbstractExecutorService {
[all...] |
| /external/jetty/src/java/org/eclipse/jetty/util/thread/ |
| ExecutorThreadPool.java | 27 import java.util.concurrent.ThreadPoolExecutor;
37 * Jetty ThreadPool using java 5 ThreadPoolExecutor
54 * Wraps an {@link ThreadPoolExecutor}.
61 // Refer to ThreadPoolExecutor javadocs for details
62 this(new ThreadPoolExecutor(256, 256, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()));
67 * Wraps an {@link ThreadPoolExecutor}.
74 this(queueSize < 0 ? new ThreadPoolExecutor(256, 256, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>()) :
75 queueSize == 0 ? new ThreadPoolExecutor(32, 256, 60, TimeUnit.SECONDS, new SynchronousQueue<Runnable>()) :
76 new ThreadPoolExecutor(32, 256, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueSize)));
81 * Wraps an {@link ThreadPoolExecutor} usin
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorTest.java | 30 import java.util.concurrent.ThreadPoolExecutor;
47 static class ExtendedTPE extends ThreadPoolExecutor {
88 final ThreadPoolExecutor p =
89 new ThreadPoolExecutor(1, 1,
110 final ThreadPoolExecutor p =
111 new ThreadPoolExecutor(2, 2,
136 final ThreadPoolExecutor p =
137 new ThreadPoolExecutor(2, 2,
154 final ThreadPoolExecutor p =
155 new ThreadPoolExecutor(2, 2
[all...] |
| ThreadPoolExecutorSubclassTest.java | 30 import java.util.concurrent.ThreadPoolExecutor;
144 static class CustomTPE extends ThreadPoolExecutor {
230 final ThreadPoolExecutor p =
252 final ThreadPoolExecutor p =
278 ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
293 ThreadPoolExecutor p = new CustomTPE(2, 2, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
307 final ThreadPoolExecutor p =
342 ThreadPoolExecutor p = new CustomTPE(1, 1, LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
351 ThreadPoolExecutor p = new CustomTPE(2, 2, 1000, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10));
361 ThreadPoolExecutor p = new CustomTPE(1,2,LONG_DELAY_MS, MILLISECONDS, new ArrayBlockingQueue<Runnable>(10), tf, new N (…)
[all...] |
| ExecutorCompletionServiceTest.java | 21 import java.util.concurrent.ThreadPoolExecutor;
177 ExecutorService e = new ThreadPoolExecutor(
209 ExecutorService e = new ThreadPoolExecutor(
|
| /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 | 28 import java.util.concurrent.ThreadPoolExecutor;
52 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,
|
| /external/vogar/src/vogar/util/ |
| Threads.java | 22 import java.util.concurrent.ThreadPoolExecutor;
50 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,
|
| /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(
|
| /packages/inputmethods/LatinIME/java/src/com/android/inputmethod/dictionarypack/ |
| DictionaryService.java | 35 import java.util.concurrent.ThreadPoolExecutor;
113 private ThreadPoolExecutor mExecutor;
124 // Executors#newSingleThreadExecutor creates a ThreadPoolExecutor but it returns the
127 mExecutor = new ThreadPoolExecutor(1 /* corePoolSize */, 1 /* maximumPoolSize */,
|
| /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 {
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| Dispatcher.java | 26 import java.util.concurrent.ThreadPoolExecutor;
61 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
|
| /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());
|
| /external/okhttp/okhttp-ws/src/main/java/com/squareup/okhttp/ws/ |
| WebSocketCall.java | 36 import java.util.concurrent.ThreadPoolExecutor;
200 ThreadPoolExecutor replyExecutor =
201 new ThreadPoolExecutor(1, 1, 1, SECONDS, new LinkedBlockingDeque<Runnable>(),
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| MoreExecutors.java | 48 import java.util.concurrent.ThreadPoolExecutor;
49 import java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy;
69 * Converts the given ThreadPoolExecutor into an ExecutorService that exits
85 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
132 * Converts the given ThreadPoolExecutor into an ExecutorService that exits
147 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) {
152 * Converts the given ThreadPoolExecutor into a ScheduledExecutorService that
176 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
213 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) {
227 private static void useDaemonThreadFactory(ThreadPoolExecutor executor)
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| JdkFutureAdaptersTest.java | 37 import java.util.concurrent.ThreadPoolExecutor;
111 ExecutorService executorService = new ThreadPoolExecutor(
|
