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()
Creates a new instance with a
Executors.newCachedThreadPool()
See OioDatagramChannelFactory(Executor) |
OioDatagramChannelFactory(Executor workerExecutor)
Creates a new instance.
|
OioDatagramChannelFactory(Executor workerExecutor,
ThreadNameDeterminer determiner)
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.
|
void |
shutdown()
Shudown the ChannelFactory and all the resource it created internal.
|
public OioDatagramChannelFactory()
Executors.newCachedThreadPool()
See OioDatagramChannelFactory(Executor)public OioDatagramChannelFactory(Executor workerExecutor)
workerExecutor - the Executor which will execute the I/O worker threadspublic OioDatagramChannelFactory(Executor workerExecutor, ThreadNameDeterminer determiner)
workerExecutor - the Executor which will execute the I/O worker threadsdeterminer - the ThreadNameDeterminer to set the thread names.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 shutdown()
ChannelFactoryshutdown in interface ChannelFactorypublic 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.
This will also call ChannelFactory.shutdown() before do any actionreleaseExternalResources in interface ChannelFactoryreleaseExternalResources in interface ExternalResourceReleasableCopyright © 2008-2015 The Netty Project. All Rights Reserved.