Package io.netty.channel

Class DefaultEventLoop

java.lang.Object

java.util.concurrent.AbstractExecutorService

io.netty.util.concurrent.AbstractEventExecutor

io.netty.util.concurrent.AbstractScheduledEventExecutor

io.netty.util.concurrent.SingleThreadEventExecutor

io.netty.channel.SingleThreadEventLoop

io.netty.channel.DefaultEventLoop

All Implemented Interfaces:

EventLoop, EventLoopGroup, EventExecutor, EventExecutorGroup, OrderedEventExecutor, AutoCloseable, Iterable<EventExecutor>, Executor, ExecutorService, ScheduledExecutorService

public class DefaultEventLoop
extends SingleThreadEventLoop

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.channel.SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T extends Channel>

Nested classes/interfaces inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

Nested classes/interfaces inherited from class io.netty.util.concurrent.AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

Field Summary

Fields inherited from class io.netty.channel.SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

Constructor Summary

Constructors

Constructor	Description
DefaultEventLoop()
DefaultEventLoop(EventLoopGroup parent)
DefaultEventLoop(EventLoopGroup parent, Executor executor)
DefaultEventLoop(EventLoopGroup parent, ThreadFactory threadFactory)
DefaultEventLoop(Executor executor)
DefaultEventLoop(ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
protected void	run()	Runs the task-processing loop until SingleThreadEventExecutor.confirmShutdown() returns true.

Methods inherited from class io.netty.channel.SingleThreadEventLoop

afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, next, parent, pendingTasks, register, register, register, registeredChannels, registeredChannelsIterator, removeAfterEventLoopIterationTask

Methods inherited from class io.netty.util.concurrent.SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, cleanup, confirmShutdown, deadlineNanos, delayNanos, execute, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isTerminated, lazyExecute, newTaskQueue, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, updateLastExecutionTime, wakesUpForTask, wakeup

Methods inherited from class io.netty.util.concurrent.AbstractScheduledEventExecutor

afterScheduledTaskSubmitted, beforeScheduledTaskSubmitted, cancelScheduledTasks, deadlineToDelayNanos, getCurrentTimeNanos, hasScheduledTasks, initialNanoTime, nanoTime, nextScheduledTaskDeadlineNanos, nextScheduledTaskNano, pollScheduledTask, pollScheduledTask, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, validateScheduled

Methods inherited from class io.netty.util.concurrent.AbstractEventExecutor

inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, newTaskFor, newTaskFor, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.util.concurrent.EventExecutor

inEventLoop, inEventLoop, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

Methods inherited from interface io.netty.util.concurrent.EventExecutorGroup

isShuttingDown, iterator, schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay, shutdown, shutdownGracefully, shutdownGracefully, shutdownNow, submit, submit, submit, terminationFuture

Methods inherited from interface java.util.concurrent.Executor

execute

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, close, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

DefaultEventLoop

public DefaultEventLoop()

DefaultEventLoop

public DefaultEventLoop(ThreadFactory threadFactory)

DefaultEventLoop

public DefaultEventLoop(Executor executor)

DefaultEventLoop

public DefaultEventLoop(EventLoopGroup parent)

DefaultEventLoop

public DefaultEventLoop(EventLoopGroup parent,
 ThreadFactory threadFactory)

DefaultEventLoop

public DefaultEventLoop(EventLoopGroup parent,
 Executor executor)

Method Details

run

protected void run()

Description copied from class: SingleThreadEventExecutor

Runs the task-processing loop until SingleThreadEventExecutor.confirmShutdown() returns true.

Implementations must not let a Throwable thrown by a task escape this method: any uncaught Throwable terminates the executor (logged at WARN and surfaced via SingleThreadEventExecutor.terminationFuture()), at which point every Channel registered with this executor stops processing I/O and new task submissions are rejected. The supplied helpers - SingleThreadEventExecutor.runAllTasks(), SingleThreadEventExecutor.runAllTasks(long), and AbstractEventExecutor.safeExecute(Runnable) - catch Throwable for you; custom loops built on SingleThreadEventExecutor.pollTask() or SingleThreadEventExecutor.takeTask() are responsible for wrapping each task invocation accordingly.

Specified by:

run in class SingleThreadEventExecutor