com.sun.sgs.impl.nio
Class ReactiveAsyncChannelProvider

java.lang.Object
  com.sun.sgs.nio.channels.spi.AsynchronousChannelProvider
      com.sun.sgs.impl.nio.AsyncProviderImpl
          com.sun.sgs.impl.nio.ReactiveAsyncChannelProvider

public class ReactiveAsyncChannelProvider
extends AsyncProviderImpl

A select-based asynchronous IO provider.

Constructor Summary

	ReactiveAsyncChannelProvider() Creates an asynchronous channel provider using the system default SelectorProvider.
protected	ReactiveAsyncChannelProvider(SelectorProvider selProvider) Creates an asynchronous channel provider using the given SelectorProvider.

Method Summary

ReactiveChannelGroup

openAsynchronousChannelGroup(ExecutorService executor) Constructs a new asynchronous channel group.

Methods inherited from class com.sun.sgs.impl.nio.AsyncProviderImpl

createDefaultThreadPoolFactory, getUncaughtExceptionHandler, openAsynchronousDatagramChannel, openAsynchronousServerSocketChannel, openAsynchronousSocketChannel, selectorProvider, setUncaughtExceptionHandler

Methods inherited from class com.sun.sgs.nio.channels.spi.AsynchronousChannelProvider

provider

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReactiveAsyncChannelProvider

public ReactiveAsyncChannelProvider()

Creates an asynchronous channel provider using the system default SelectorProvider. Public visibility to allow instantiation from a property at runtime.

See Also:

SelectorProvider.provider()

ReactiveAsyncChannelProvider

protected ReactiveAsyncChannelProvider(SelectorProvider selProvider)

Creates an asynchronous channel provider using the given SelectorProvider. If the parameter is null, the system default SelectorProvider will be used.

Parameters:

selProvider - the SelectorProvider, or null to use the system default SelectorProvider

See Also:

SelectorProvider.provider()

Method Detail

openAsynchronousChannelGroup

public ReactiveChannelGroup openAsynchronousChannelGroup(ExecutorService executor)
                                                  throws IOException

Constructs a new asynchronous channel group.

Specified by:

openAsynchronousChannelGroup in class AsyncProviderImpl

Parameters:

executor - the executor service

Returns:

a new asynchronous channel group

Throws:

IOException - if an I/O error occurs