| /openjdk7/jdk/test/java/nio/channels/spi/AsynchronousChannelProvider/ |
| H A D | Provider1.java | 35 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factorry) argument
|
| H A D | Provider2.java | 36 (int nThreads, ThreadFactory threadFactory) throws IOException
35 openAsynchronousChannelGroup(int nThreads, ThreadFactory threadFactory) argument
|
| /openjdk7/hotspot/test/compiler/7009231/ |
| H A D | Test7009231.java | 43 private static void doTest(int nThreads) throws InterruptedException { argument
44 Thread[] aThreads = new Thread[nThreads];
47 for (int i = 0; i < nThreads; i++) {
51 for (int i = 0; i < nThreads; i++) {
55 for (int i = 0; i < nThreads; i++) {
|
| /openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
| H A D | WindowsAsynchronousChannelProvider.java | 56 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) argument
59 return new Iocp(this, ThreadPool.create(nThreads, factory)).start();
|
| /openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
| H A D | BsdAsynchronousChannelProvider.java | 54 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) argument
57 return new KQueuePort(this, ThreadPool.create(nThreads, factory)).start();
|
| H A D | LinuxAsynchronousChannelProvider.java | 54 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) argument
57 return new EPollPort(this, ThreadPool.create(nThreads, factory)).start();
|
| H A D | SolarisAsynchronousChannelProvider.java | 55 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) argument
58 return new SolarisEventPort(this, ThreadPool.create(nThreads, factory)).start();
|
| /openjdk7/jdk/src/share/classes/java/nio/channels/ |
| H A D | AsynchronousChannelGroup.java | 160 * threads. At any point, at most {@code nThreads} threads will be active
170 * @param nThreads
178 * If {@code nThreads <= 0}
182 public static AsynchronousChannelGroup withFixedThreadPool(int nThreads, argument
187 .openAsynchronousChannelGroup(nThreads, threadFactory);
|
| /openjdk7/jdk/src/share/classes/java/nio/channels/spi/ |
| H A D | AsynchronousChannelProvider.java | 172 * @param nThreads
178 * If {@code nThreads <= 0}
185 openAsynchronousChannelGroup(int nThreads, ThreadFactory threadFactory) throws IOException; argument
|
| /openjdk7/jdk/test/java/nio/channels/FileChannel/ |
| H A D | ClosedByInterrupt.java | 68 * Starts "nThreads" that do I/O on the given file concurrently. Continuously
73 static void test(File f, int nThreads) throws Exception { argument
75 Thread[] threads = new Thread[nThreads];
78 for (int i=0; i<nThreads; i++) {
96 for (int i=0; i<nThreads; i++) {
|
| /openjdk7/jdk/src/share/classes/sun/nio/ch/ |
| H A D | ThreadPool.java | 114 static ThreadPool create(int nThreads, ThreadFactory factory) { argument
115 if (nThreads <= 0)
116 throw new IllegalArgumentException("'nThreads' must be > 0");
117 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory);
118 return new ThreadPool(executor, true, nThreads);
|
| /openjdk7/jdk/src/share/classes/java/util/concurrent/ |
| H A D | Executors.java | 76 * <tt>nThreads</tt> threads will be active processing tasks.
84 * @param nThreads the number of threads in the pool
86 * @throws IllegalArgumentException if {@code nThreads <= 0}
88 public static ExecutorService newFixedThreadPool(int nThreads) { argument
89 return new ThreadPoolExecutor(nThreads, nThreads,
98 * at most <tt>nThreads</tt> threads will be active processing
107 * @param nThreads the number of threads in the pool
111 * @throws IllegalArgumentException if {@code nThreads <= 0}
113 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactor argument
[all...] |