Searched refs:AsynchronousChannelGroup (Results 1 - 19 of 19) sorted by relevance

/openjdk7/jdk/test/java/nio/channels/spi/AsynchronousChannelProvider/
H A DProvider1.java35 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 DProvider2.java35 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 DAsynchronousChannelGroup.java130 * @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 DAsynchronousServerSocketChannel.java135 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 DAsynchronousSocketChannel.java159 public static AsynchronousSocketChannel open(AsynchronousChannelGroup group)
174 * open((AsynchronousChannelGroup)null);
/openjdk7/jdk/test/java/nio/channels/AsynchronousChannelGroup/
H A DAsExecutor.java24 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 DBasic.java26 * @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 DRestart.java26 * @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 DIdentity.java26 * @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 DGroupOfOne.java26 * @summary Unit test for AsynchronousChannelGroup
82 final AsynchronousChannelGroup group = AsynchronousChannelGroup
/openjdk7/jdk/src/windows/classes/sun/nio/ch/
H A DWindowsAsynchronousChannelProvider.java56 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 DBsdAsynchronousChannelProvider.java54 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 DLinuxAsynchronousChannelProvider.java54 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 DSolarisAsynchronousChannelProvider.java55 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 DAsynchronousChannelProvider.java182 * @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 DChatServer.java58 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 DLeaky.java56 Connection(AsynchronousChannelGroup group) throws Exception {
92 AsynchronousChannelGroup group =
93 AsynchronousChannelGroup.withFixedThreadPool(4, threadFactory);
/openjdk7/jdk/src/share/classes/sun/nio/ch/
H A DAsynchronousChannelGroupImpl.java29 import java.nio.channels.AsynchronousChannelGroup;
43 * Base implementation of AsynchronousChannelGroup
47 extends AsynchronousChannelGroup implements Executor
/openjdk7/jdk/make/java/nio/
H A DFILES_java.gmk35 java/nio/channels/AsynchronousChannelGroup.java \

Completed in 52 milliseconds