| /openjdk7/jdk/src/share/classes/java/util/concurrent/ |
| H A D | RejectedExecutionHandler.java | 39 * A handler for tasks that cannot be executed by a {@link ThreadPoolExecutor}.
47 * Method that may be invoked by a {@link ThreadPoolExecutor} when
48 * {@link ThreadPoolExecutor#execute execute} cannot accept a
61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
|
| H A D | Executors.java | 89 return new ThreadPoolExecutor(nThreads, nThreads,
114 return new ThreadPoolExecutor(nThreads, nThreads,
135 (new ThreadPoolExecutor(1, 1,
156 (new ThreadPoolExecutor(1, 1,
174 * may be created using {@link ThreadPoolExecutor} constructors.
179 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
194 return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
339 * any task runs in {@link ThreadPoolExecutor} subclasses using
340 * {@link ThreadPoolExecutor#beforeExecute}. Also, if it is
|
| H A D | ThreadPoolExecutor.java | 53 * Each {@code ThreadPoolExecutor} also maintains some basic
72 * <dd>A {@code ThreadPoolExecutor} will automatically adjust the
211 * <li> In the default {@link ThreadPoolExecutor.AbortPolicy}, the
215 * <li> In {@link ThreadPoolExecutor.CallerRunsPolicy}, the thread
220 * <li> In {@link ThreadPoolExecutor.DiscardPolicy}, a task that
223 * <li>In {@link ThreadPoolExecutor.DiscardOldestPolicy}, if the
275 * class PausableThreadPoolExecutor extends ThreadPoolExecutor {
317 public class ThreadPoolExecutor extends AbstractExecutorService { class in inherits:AbstractExecutorService
1170 * Creates a new {@code ThreadPoolExecutor} with the given initial
1193 public ThreadPoolExecutor(in method in class:ThreadPoolExecutor
1227 public ThreadPoolExecutor(int corePoolSize, method in class:ThreadPoolExecutor
1262 public ThreadPoolExecutor(int corePoolSize, method in class:ThreadPoolExecutor
1299 public ThreadPoolExecutor(int corePoolSize, method in class:ThreadPoolExecutor
[all...] |
| H A D | ScheduledThreadPoolExecutor.java | 42 * A {@link ThreadPoolExecutor} that can additionally schedule
46 * flexibility or capabilities of {@link ThreadPoolExecutor} (which
72 * <p>While this class inherits from {@link ThreadPoolExecutor}, a few
82 * {@link ThreadPoolExecutor#execute execute} and
120 extends ThreadPoolExecutor
124 * This class specializes ThreadPoolExecutor implementation by
136 * (see delayedExecute) compared to ThreadPoolExecutor.
607 * that {@link ThreadPoolExecutor#afterExecute afterExecute} is always
|
| /openjdk7/jdk/test/java/util/concurrent/ThreadPoolExecutor/ |
| H A D | TimeOutShrink.java | 35 static void checkPoolSizes(ThreadPoolExecutor pool,
45 final ThreadPoolExecutor pool
46 = new ThreadPoolExecutor(n, 2*n, 1L, TimeUnit.SECONDS,
|
| H A D | ConfigChanges.java | 43 static void report(ThreadPoolExecutor tpe) {
57 static void report(String label, ThreadPoolExecutor tpe) {
71 if (es instanceof ThreadPoolExecutor)
72 check(((ThreadPoolExecutor) es).isTerminating()
80 static void checkTerminated(final ThreadPoolExecutor tpe) {
115 final ThreadPoolExecutor tpe
116 = new ThreadPoolExecutor(n, 3*n,
|
| H A D | ShutdownNowExecuteRace.java | 34 // in ThreadPoolExecutor.addWorker.
41 static volatile ThreadPoolExecutor pool = null;
53 ThreadPoolExecutor pool = ShutdownNowExecuteRace.pool;
60 pool = new ThreadPoolExecutor(
|
| H A D | ModifyCorePoolSize.java | 34 static void awaitPoolSize(ThreadPoolExecutor pool, int n) {
39 static void setCorePoolSize(ThreadPoolExecutor pool, int n) {
|
| H A D | SelfInterrupt.java | 35 final ThreadPoolExecutor pool =
36 new ThreadPoolExecutor(n, n, 1L, TimeUnit.NANOSECONDS,
|
| H A D | CoreThreadTimeOut.java | 67 ThreadPoolExecutor tpe
68 = new ThreadPoolExecutor(threadCount, threadCount,
|
| H A D | Custom.java | 51 private static class CustomTPE extends ThreadPoolExecutor {
|
| H A D | ThrowingTasks.java | 143 static void checkTerminated(ThreadPoolExecutor tpe) {
156 static class CheckingExecutor extends ThreadPoolExecutor {
|
| /openjdk7/jdk/test/java/util/concurrent/ScheduledThreadPoolExecutor/ |
| H A D | BasicCancelTest.java | 45 if (es instanceof ThreadPoolExecutor)
46 check(((ThreadPoolExecutor) es).isTerminating()
54 void checkTerminated(final ThreadPoolExecutor tpe) {
|
| /openjdk7/jdk/src/share/classes/sun/nio/ch/ |
| H A D | ThreadPool.java | 106 new ThreadPoolExecutor(0, Integer.MAX_VALUE,
126 if (executor instanceof ThreadPoolExecutor) {
127 int max = ((ThreadPoolExecutor)executor).getMaximumPoolSize();
|
| /openjdk7/jdk/test/javax/management/notification/ |
| H A D | NotifExecutorTest.java | 173 public static class MyExecutor extends ThreadPoolExecutor {
|
| /openjdk7/jdk/test/java/util/concurrent/Executors/ |
| H A D | Throws.java | 45 ThreadPoolExecutor executor) {}};
|
| /openjdk7/jdk/src/share/classes/javax/management/monitor/ |
| H A D | Monitor.java | 46 import java.util.concurrent.ThreadPoolExecutor;
184 private static final Map<ThreadPoolExecutor, Void> executors =
185 new WeakHashMap<ThreadPoolExecutor, Void>();
1512 private ThreadPoolExecutor executor;
1531 for (ThreadPoolExecutor e : executors.keySet()) {
1541 executor = new ThreadPoolExecutor(
|
| /openjdk7/jdk/src/share/classes/javax/swing/ |
| H A D | SwingWorker.java | 777 new ThreadPoolExecutor(MAX_WORKER_THREADS, MAX_WORKER_THREADS,
|
| /openjdk7/jdk/src/share/classes/sun/rmi/transport/tcp/ |
| H A D | TCPTransport.java | 62 import java.util.concurrent.ThreadPoolExecutor;
108 new ThreadPoolExecutor(0, maxConnectionThreads,
|
| /openjdk7/jdk/src/windows/classes/sun/awt/shell/ |
| H A D | Win32ShellFolderManager2.java | 470 private static class ComInvoker extends ThreadPoolExecutor implements ThreadFactory, ShellFolder.Invoker {
|
| /openjdk7/jdk/make/java/java/ |
| H A D | FILES_java.gmk | 330 java/util/concurrent/ThreadPoolExecutor.java \
|