Class OioEventLoopGroup
java.lang.Object
io.netty.util.concurrent.AbstractEventExecutorGroup
io.netty.channel.ThreadPerChannelEventLoopGroup
io.netty.channel.oio.OioEventLoopGroup
- All Implemented Interfaces:
EventLoopGroup, EventExecutorGroup, Iterable<EventExecutor>, Executor, ExecutorService, ScheduledExecutorService
Deprecated.
use NIO / EPOLL / KQUEUE transport.
EventLoopGroup which is used to handle OIO Channel's. Each Channel will be handled by its
own EventLoop to not block others.-
Constructor Summary
ConstructorsConstructorDescriptionDeprecated.Create a newOioEventLoopGroupwith no limit in place.OioEventLoopGroup(int maxChannels) Deprecated.Create a newOioEventLoopGroup.OioEventLoopGroup(int maxChannels, Executor executor) Deprecated.Create a newOioEventLoopGroup.OioEventLoopGroup(int maxChannels, ThreadFactory threadFactory) Deprecated.Create a newOioEventLoopGroup. -
Method Summary
Methods inherited from class ThreadPerChannelEventLoopGroup
awaitTermination, isShutdown, isShuttingDown, isTerminated, iterator, newChild, next, register, register, register, shutdown, shutdownGracefully, terminationFutureModifier and TypeMethodDescriptionbooleanawaitTermination(long timeout, TimeUnit unit) Deprecated.booleanDeprecated.booleanDeprecated.Returnstrueif and only if allEventExecutors managed by thisEventExecutorGroupare being shut down gracefully or was shut down.booleanDeprecated.iterator()Deprecated.protected EventLoopDeprecated.Creates a newEventLoop.next()Deprecated.Returns one of theEventExecutors managed by thisEventExecutorGroup.register(ChannelPromise promise) Deprecated.register(Channel channel, ChannelPromise promise) Deprecated.voidshutdown()Deprecated.Future<?> shutdownGracefully(long quietPeriod, long timeout, TimeUnit unit) Deprecated.Signals this executor that the caller wants the executor to be shut down.Future<?> Deprecated.Returns theFuturewhich is notified when allEventExecutors managed by thisEventExecutorGrouphave been terminated.Methods inherited from class AbstractEventExecutorGroup
execute, invokeAll, invokeAll, invokeAny, invokeAny, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdownGracefully, shutdownNow, submit, submit, submitModifier and TypeMethodDescriptionvoidinvokeAll(Collection<? extends Callable<T>> tasks) invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) <T> TinvokeAny(Collection<? extends Callable<T>> tasks) <T> TinvokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) <V> ScheduledFuture<V> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) Future<?> Shortcut method forEventExecutorGroup.shutdownGracefully(long, long, TimeUnit)with sensible default values.Future<?> <T> Future<T> <T> Future<T> Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface Iterable
forEach, spliterator
-
Constructor Details
-
OioEventLoopGroup
-
OioEventLoopGroup
public OioEventLoopGroup(int maxChannels) Deprecated.Create a newOioEventLoopGroup.- Parameters:
maxChannels- the maximum number of channels to handle with this instance. Once you try to register a newChanneland the maximum is exceed it will throw anChannelExceptionon theThreadPerChannelEventLoopGroup.register(Channel)andThreadPerChannelEventLoopGroup.register(ChannelPromise)method. Use0to use no limit
-
OioEventLoopGroup
Deprecated.Create a newOioEventLoopGroup.- Parameters:
maxChannels- the maximum number of channels to handle with this instance. Once you try to register a newChanneland the maximum is exceed it will throw anChannelExceptionon theThreadPerChannelEventLoopGroup.register(Channel)andThreadPerChannelEventLoopGroup.register(ChannelPromise)method. Use0to use no limitexecutor- theExecutorused to create newThreadinstances that handle the registeredChannels
-
OioEventLoopGroup
Deprecated.Create a newOioEventLoopGroup.- Parameters:
maxChannels- the maximum number of channels to handle with this instance. Once you try to register a newChanneland the maximum is exceed it will throw anChannelExceptionon theThreadPerChannelEventLoopGroup.register(Channel)andThreadPerChannelEventLoopGroup.register(ChannelPromise)method. Use0to use no limitthreadFactory- theThreadFactoryused to create newThreadinstances that handle the registeredChannels
-