| /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 | 66 return new ThreadPoolExecutor(nThreads, nThreads,
129 return new ThreadPoolExecutor(nThreads, nThreads,
150 (new ThreadPoolExecutor(1, 1,
171 (new ThreadPoolExecutor(1, 1,
189 * may be created using {@link ThreadPoolExecutor} constructors.
194 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
209 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
|
| ThreadPoolExecutor.java | 33 * Each {@code ThreadPoolExecutor} also maintains some basic
53 * A {@code ThreadPoolExecutor} will automatically adjust the
192 * RejectedExecutionHandler#rejectedExecution(Runnable, ThreadPoolExecutor)}
198 * <li>In the default {@link ThreadPoolExecutor.AbortPolicy}, the
202 * <li>In {@link ThreadPoolExecutor.CallerRunsPolicy}, the thread
207 * <li>In {@link ThreadPoolExecutor.DiscardPolicy}, a task that
210 * <li>In {@link ThreadPoolExecutor.DiscardOldestPolicy}, if the
267 * class PausableThreadPoolExecutor extends ThreadPoolExecutor {
309 public class ThreadPoolExecutor extends AbstractExecutorService {
[all...] |
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| ThreadPoolExecutorTest.java | 22 import java.util.concurrent.ThreadPoolExecutor;
29 ThreadPoolExecutor tp = new ThreadPoolExecutor(
|
| /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...] |
| /external/sl4a/Utils/src/com/googlecode/android_scripting/ |
| SingleThreadExecutor.java | 20 import java.util.concurrent.ThreadPoolExecutor;
23 public class SingleThreadExecutor extends ThreadPoolExecutor {
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorTest.java | 32 import java.util.concurrent.ThreadPoolExecutor;
50 static class ExtendedTPE extends ThreadPoolExecutor {
91 final ThreadPoolExecutor p =
92 new ThreadPoolExecutor(1, 1,
110 final ThreadPoolExecutor p =
111 new ThreadPoolExecutor(2, 2,
132 final ThreadPoolExecutor p =
133 new ThreadPoolExecutor(2, 6,
158 final ThreadPoolExecutor p =
159 new ThreadPoolExecutor(2, 6
[all...] |
| ThreadPoolExecutorSubclassTest.java | 32 import java.util.concurrent.ThreadPoolExecutor;
152 static class CustomTPE extends ThreadPoolExecutor {
238 final ThreadPoolExecutor p =
257 final ThreadPoolExecutor p =
279 final ThreadPoolExecutor p =
305 final ThreadPoolExecutor p =
328 final ThreadPoolExecutor p =
361 final ThreadPoolExecutor p =
374 final ThreadPoolExecutor p =
388 final ThreadPoolExecutor p
[all...] |
| /development/samples/WiFiDirectServiceDiscovery/src/com/example/android/wifidirect/discovery/ |
| GroupOwnerSocketHandler.java | 10 import java.util.concurrent.ThreadPoolExecutor;
40 private final ThreadPoolExecutor pool = 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,
|
| /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/testng/src/main/java/org/testng/internal/thread/ |
| ExecutorAdapter.java | 7 import java.util.concurrent.ThreadPoolExecutor;
11 * An implementation for <code>IExecutor</code> based on <code>ThreadPoolExecutor</code>
15 public class ExecutorAdapter extends ThreadPoolExecutor implements IExecutor {
45 System.out.println("[WARN] ThreadPoolExecutor has been interrupted while awaiting termination");
|
| ThreadUtil.java | 12 import java.util.concurrent.ThreadPoolExecutor;
46 new ThreadPoolExecutor(threadPoolSize, threadPoolSize,
|
| /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,
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| ThreadPool.java | 106 new ThreadPoolExecutor(0, Integer.MAX_VALUE,
126 if (executor instanceof ThreadPoolExecutor) {
127 int max = ((ThreadPoolExecutor)executor).getMaximumPoolSize();
|
| /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,
|
| /external/testng/src/main/java/org/testng/internal/thread/graph/ |
| GraphThreadPoolExecutor.java | 15 import java.util.concurrent.ThreadPoolExecutor;
23 public class GraphThreadPoolExecutor<T> extends ThreadPoolExecutor {
|
| /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());
|
