/openjdk7/jdk/test/java/nio/channels/spi/AsynchronousChannelProvider/ |
H A D | Provider1.java | 35 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factorry) 42 public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize) 50 (AsynchronousChannelGroup group) throws IOException 57 (AsynchronousChannelGroup group) throws IOException
|
H A D | Provider2.java | 35 public AsynchronousChannelGroup openAsynchronousChannelGroup 42 public AsynchronousChannelGroup openAsynchronousChannelGroup 50 (AsynchronousChannelGroup group) throws IOException 57 (AsynchronousChannelGroup group) throws IOException
|
/openjdk7/jdk/src/share/classes/java/nio/channels/ |
H A D | AsynchronousChannelGroup.java | 130 * @see AsynchronousSocketChannel#open(AsynchronousChannelGroup) 131 * @see AsynchronousServerSocketChannel#open(AsynchronousChannelGroup) 134 public abstract class AsynchronousChannelGroup { class 143 protected AsynchronousChannelGroup(AsynchronousChannelProvider provider) { method in class:AsynchronousChannelGroup 182 public static AsynchronousChannelGroup withFixedThreadPool(int nThreads, 229 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, 270 public static AsynchronousChannelGroup withThreadPool(ExecutorService executor)
|
H A D | AsynchronousServerSocketChannel.java | 135 public static AsynchronousServerSocketChannel open(AsynchronousChannelGroup group) 150 * open((AsynchronousChannelGroup)null); 248 * AsynchronousChannelGroup} as this channel. If the group is {@link 249 * AsynchronousChannelGroup#isShutdown shutdown} and a connection is accepted, 256 * href="AsynchronousChannelGroup.html#threading">Threading<a>).
|
H A D | AsynchronousSocketChannel.java | 159 public static AsynchronousSocketChannel open(AsynchronousChannelGroup group) 174 * open((AsynchronousChannelGroup)null);
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousChannelGroup/ |
H A D | AsExecutor.java | 24 import java.nio.channels.AsynchronousChannelGroup; 36 AsynchronousChannelGroup group1 = AsynchronousChannelGroup 38 AsynchronousChannelGroup group2 = AsynchronousChannelGroup 61 static void testSimpleTask(AsynchronousChannelGroup group) throws Exception { 72 static void testAttackingTask(AsynchronousChannelGroup group) throws Exception {
|
H A D | Basic.java | 26 * @summary Unit test for AsynchronousChannelGroup 60 AsynchronousChannelGroup group; 63 group = AsynchronousChannelGroup.withCachedThreadPool(pool, rand.nextInt(5)); 66 group = AsynchronousChannelGroup.withFixedThreadPool(nThreads, threadFactory); 82 AsynchronousChannelGroup group; 85 group = AsynchronousChannelGroup.withCachedThreadPool(pool, rand.nextInt(10)); 88 group = AsynchronousChannelGroup.withFixedThreadPool(nThreads, threadFactory); 118 AsynchronousChannelGroup group; 121 group = AsynchronousChannelGroup 125 group = AsynchronousChannelGroup [all...] |
H A D | Restart.java | 26 * @summary Unit test for AsynchronousChannelGroup 69 AsynchronousChannelGroup group = 70 AsynchronousChannelGroup.withFixedThreadPool(nThreads, factory); 76 group = AsynchronousChannelGroup.withCachedThreadPool(pool, rand.nextInt(5)); 87 static void testRestart(AsynchronousChannelGroup group, int count)
|
H A D | Identity.java | 26 * @summary Unit test for AsynchronousChannelGroup 108 AsynchronousChannelGroup[] groups = new AsynchronousChannelGroup[groupCount]; 112 AsynchronousChannelGroup group; 115 group = AsynchronousChannelGroup.withFixedThreadPool(nThreads, factory); 118 group = AsynchronousChannelGroup.withCachedThreadPool(pool, rand.nextInt(5)); 155 for (AsynchronousChannelGroup group: groups)
|
H A D | GroupOfOne.java | 26 * @summary Unit test for AsynchronousChannelGroup 82 final AsynchronousChannelGroup group = AsynchronousChannelGroup
|
/openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
H A D | WindowsAsynchronousChannelProvider.java | 56 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) 63 public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize) 69 private Iocp toIocp(AsynchronousChannelGroup group) throws IOException { 80 public AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(AsynchronousChannelGroup group) 87 public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group)
|
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | BsdAsynchronousChannelProvider.java | 54 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) 61 public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize) 67 private Port toPort(AsynchronousChannelGroup group) throws IOException { 78 public AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(AsynchronousChannelGroup group) 85 public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group)
|
H A D | LinuxAsynchronousChannelProvider.java | 54 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) 61 public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize) 67 private Port toPort(AsynchronousChannelGroup group) throws IOException { 78 public AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(AsynchronousChannelGroup group) 85 public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group)
|
H A D | SolarisAsynchronousChannelProvider.java | 55 public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory) 62 public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize) 68 private SolarisEventPort toEventPort(AsynchronousChannelGroup group) 81 public AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(AsynchronousChannelGroup group) 88 public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group)
|
/openjdk7/jdk/src/share/classes/java/nio/channels/spi/ |
H A D | AsynchronousChannelProvider.java | 182 * @see AsynchronousChannelGroup#withFixedThreadPool 184 public abstract AsynchronousChannelGroup 199 * @see AsynchronousChannelGroup#withCachedThreadPool 201 public abstract AsynchronousChannelGroup 221 (AsynchronousChannelGroup group) throws IOException; 240 (AsynchronousChannelGroup group) throws IOException;
|
/openjdk7/jdk/src/share/sample/nio/chatserver/ |
H A D | ChatServer.java | 58 private final AsynchronousChannelGroup channelGroup; 66 channelGroup = AsynchronousChannelGroup.withFixedThreadPool(Runtime.getRuntime().availableProcessors(), 115 private AsynchronousServerSocketChannel createListener(AsynchronousChannelGroup channelGroup) throws IOException { 122 private AsynchronousServerSocketChannel openChannel(AsynchronousChannelGroup channelGroup) throws IOException {
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
H A D | Leaky.java | 56 Connection(AsynchronousChannelGroup group) throws Exception { 92 AsynchronousChannelGroup group = 93 AsynchronousChannelGroup.withFixedThreadPool(4, threadFactory);
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | AsynchronousChannelGroupImpl.java | 29 import java.nio.channels.AsynchronousChannelGroup; 43 * Base implementation of AsynchronousChannelGroup 47 extends AsynchronousChannelGroup implements Executor
|
/openjdk7/jdk/make/java/nio/ |
H A D | FILES_java.gmk | 35 java/nio/channels/AsynchronousChannelGroup.java \
|