Class KQueueEventLoopGroup.KQueueEventLoop

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.SingleThreadIoEventLoop

io.netty.channel.kqueue.KQueueEventLoopGroup.KQueueEventLoop

All Implemented Interfaces:

EventLoop, EventLoopGroup, IoEventLoop, IoEventLoopGroup, EventExecutor, EventExecutorGroup, OrderedEventExecutor, ThreadAwareExecutor, Iterable<EventExecutor>, Executor, ExecutorService, ScheduledExecutorService

Enclosing class:

KQueueEventLoopGroup

private static final class KQueueEventLoopGroup.KQueueEventLoop
extends SingleThreadIoEventLoop

Nested Class Summary

Nested classes/interfaces inherited from class SingleThreadEventLoop

SingleThreadEventLoop.ChannelsReadOnlyIterator<T>

Nested classes/interfaces inherited from class SingleThreadEventExecutor

SingleThreadEventExecutor.NonWakeupRunnable

Nested classes/interfaces inherited from class AbstractEventExecutor

AbstractEventExecutor.LazyRunnable

Field Summary

Fields inherited from class SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

Constructor Summary

Constructors

Constructor	Description
KQueueEventLoop(IoEventLoopGroup parent, Executor executor, IoHandlerFactory ioHandlerFactory, Queue<Runnable> taskQueue, Queue<Runnable> tailTaskQueue, RejectedExecutionHandler rejectedExecutionHandler)

Method Summary

Modifier and Type	Method	Description
(package private) static Queue<Runnable>	newTaskQueue(EventLoopTaskQueueFactory queueFactory)
int	registeredChannels()	Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
Iterator<Channel>	registeredChannelsIterator()

Methods inherited from class SingleThreadIoEventLoop

canSuspend, cleanup, getNumOfRegisteredChannels, ioHandler, isCompatible, isIoType, newTaskQueue, newTaskQueue0, next, register, run, runIo, wakeup

Methods inherited from class SingleThreadEventLoop

afterRunningAllTasks, executeAfterEventLoopIteration, hasTasks, parent, pendingTasks, register, register, register

Methods inherited from class SingleThreadEventExecutor

addShutdownHook, addTask, awaitTermination, canSuspend, confirmShutdown, deadlineNanos, delayNanos, execute, getAndIncrementBusyCycles, getAndIncrementIdleCycles, getAndResetAccumulatedActiveTimeNanos, getLastActivityTimeNanos, inEventLoop, interruptThread, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isShuttingDown, isSuspended, isSuspensionSupported, isTerminated, lazyExecute, newTaskQueue, peekTask, pollTask, pollTaskFrom, reject, reject, removeShutdownHook, removeTask, reportActiveIoTime, resetBusyCycles, resetIdleCycles, runAllTasks, runAllTasks, runAllTasksFrom, runScheduledAndExecutorTasks, shutdown, shutdownGracefully, takeTask, terminationFuture, threadProperties, trySuspend, updateLastExecutionTime, wakesUpForTask

Methods inherited from class AbstractScheduledEventExecutor

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

Methods inherited from class AbstractEventExecutor

iterator, newTaskFor, newTaskFor, runTask, safeExecute, shutdownGracefully, shutdownNow, submit, submit, submit

Methods inherited from class Object

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

Methods inherited from interface EventExecutor

inEventLoop, inEventLoop, isExecutorThread, isSuspended, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, trySuspend

Methods inherited from interface EventExecutorGroup

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

Methods inherited from interface EventLoop

parent

Methods inherited from interface EventLoopGroup

register

Methods inherited from interface Executor

execute

Methods inherited from interface ExecutorService

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

Methods inherited from interface IoEventLoopGroup

register, register

Methods inherited from interface Iterable

forEach, spliterator

Constructor Details

KQueueEventLoop

KQueueEventLoop(IoEventLoopGroup parent,
 Executor executor,
 IoHandlerFactory ioHandlerFactory,
 Queue<Runnable> taskQueue,
 Queue<Runnable> tailTaskQueue,
 RejectedExecutionHandler rejectedExecutionHandler)

Method Details

newTaskQueue

static Queue<Runnable> newTaskQueue(EventLoopTaskQueueFactory queueFactory)

registeredChannels

public int registeredChannels()

Description copied from class: SingleThreadEventLoop

Returns the number of Channels registered with this EventLoop or -1 if operation is not supported. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort.

Overrides:

registeredChannels in class SingleThreadEventLoop

registeredChannelsIterator

public Iterator<Channel> registeredChannelsIterator()

Overrides:

registeredChannelsIterator in class SingleThreadEventLoop

Returns:

read-only iterator of active Channels registered with this EventLoop. The returned value is not guaranteed to be exact accurate and should be viewed as a best effort. This method is expected to be called from within event loop.