
public class OioDatagramChannelFactory extends Object implements DatagramChannelFactory
DatagramChannelFactory which creates a blocking I/O based
DatagramChannel. It utilizes the good old blocking I/O API which
has support for multicast.
There is only one type of threads in OioDatagramChannelFactory;
worker threads.
Each Channel has a dedicated worker thread, just like a
traditional blocking I/O thread model.
Worker threads are acquired from the Executor which was specified
when a OioDatagramChannelFactory was created (i.e. workerExecutor.)
Therefore, you should make sure the specified Executor is able to
lend the sufficient number of threads.
Worker threads are acquired lazily, and then released when there's nothing left to process. All the related resources are also released when the worker threads are released. Therefore, to shut down a service gracefully, you should do the following:
ChannelGroup.close(), andreleaseExternalResources().RejectedExecutionException
and the related resources might not be released properly.
A DatagramChannel created by this factory does not support asynchronous
operations. Any I/O requests such as "write" will be performed in a
blocking manner.
| Constructor and Description |
|---|
OioDatagramChannelFactory(Executor workerExecutor)
Creates a new instance.
|
| Modifier and Type | Method and Description |
|---|---|
DatagramChannel |
newChannel(ChannelPipeline pipeline)
|
void |
releaseExternalResources()
Releases the external resources that this factory depends on to function.
|
public DatagramChannel newChannel(ChannelPipeline pipeline)
ChannelFactorynewChannel in interface ChannelFactorynewChannel in interface DatagramChannelFactorypipeline - the ChannelPipeline which is going to be
attached to the new Channelpublic void releaseExternalResources()
ChannelFactoryExecutors that you specified in the factory
constructor are external resources. You can call this method to release
all external resources conveniently when the resources are not used by
this factory or any other part of your application. An unexpected
behavior will be resulted in if the resources are released when there's
an open channel which is managed by this factory.releaseExternalResources in interface ChannelFactoryreleaseExternalResources in interface ExternalResourceReleasableCopyright © 2008-2013 JBoss, by Red Hat. All Rights Reserved.