Class 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.kqueue.KQueueEventLoop

All Implemented Interfaces:

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

final class KQueueEventLoop
extends SingleThreadEventLoop

EventLoop which uses kqueue under the covers. Only works on BSD!

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	KQueueEventLoop.KQueueRegistration

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

Modifier and Type	Field	Description
private final boolean	allowGrowing
private final Queue<KQueueEventLoop.KQueueRegistration>	cancelledRegistrations
private final KQueueEventArray	changeList
private final KQueueEventArray	eventList
private int	ioRatio
private final IovArray	iovArray
private static final int	KQUEUE_MAX_TIMEOUT_SECONDS
private static final int	KQUEUE_WAKE_UP_IDENT
private final FileDescriptor	kqueueFd
private static final InternalLogger	logger
private long	nextId
private final LongObjectMap<KQueueEventLoop.KQueueRegistration>	registrations
private final IntSupplier	selectNowSupplier
private final SelectStrategy	selectStrategy
private static final AtomicIntegerFieldUpdater<KQueueEventLoop>	WAKEN_UP_UPDATER
private int	wakenUp

Fields inherited from class SingleThreadEventLoop

DEFAULT_MAX_PENDING_TASKS

Constructor Summary

Constructors

Constructor	Description
KQueueEventLoop(EventLoopGroup parent, Executor executor, int maxEvents, SelectStrategy strategy, RejectedExecutionHandler rejectedExecutionHandler, EventLoopTaskQueueFactory taskQueueFactory, EventLoopTaskQueueFactory tailTaskQueueFactory)

Method Summary

Modifier and Type	Method	Description
(package private) KQueueEventLoop.KQueueRegistration	add(AbstractKQueueChannel ch)
(package private) IovArray	cleanArray()	Return a cleared IovArray that can be used for writes in this EventLoop.
protected void	cleanup()	Do nothing, sub-classes may override
private void	closeAll()
private long	generateNextId()
int	getIoRatio()	Returns the percentage of the desired amount of time spent for I/O in the event loop.
private static void	handleLoopException(Throwable t)
private int	kqueueWait(boolean oldWakeup)
private int	kqueueWait(int timeoutSec, int timeoutNs)
private int	kqueueWaitNow()
protected Queue<Runnable>	newTaskQueue(int maxPendingTasks)	Create a new Queue which will holds the tasks to execute.
private static Queue<Runnable>	newTaskQueue(EventLoopTaskQueueFactory queueFactory)
private static Queue<Runnable>	newTaskQueue0(int maxPendingTasks)
private void	processCancelledRegistrations()
private void	processReady(int ready)
int	registeredChannels()	Returns the number of Channels registered with this EventLoop or -1 if operation is not supported.
Iterator<Channel>	registeredChannelsIterator()
protected void	run()	Run the tasks in the SingleThreadEventExecutor.taskQueue
void	setIoRatio(int ioRatio)	Sets the percentage of the desired amount of time spent for I/O in the event loop.
private void	wakeup()
protected void	wakeup(boolean inEventLoop)

Methods inherited from class SingleThreadEventLoop

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

Methods inherited from class SingleThreadEventExecutor

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

Methods inherited from class AbstractScheduledEventExecutor

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

Methods inherited from class AbstractEventExecutor

inEventLoop, iterator, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, 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, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture

Methods inherited from interface EventExecutorGroup

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

Methods inherited from interface Executor

execute

Methods inherited from interface ExecutorService

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

Methods inherited from interface Iterable

forEach, spliterator

Field Details

logger

private static final InternalLogger logger

WAKEN_UP_UPDATER

private static final AtomicIntegerFieldUpdater<KQueueEventLoop> WAKEN_UP_UPDATER

KQUEUE_WAKE_UP_IDENT

private static final int KQUEUE_WAKE_UP_IDENT

See Also:

• Constant Field Values

KQUEUE_MAX_TIMEOUT_SECONDS

private static final int KQUEUE_MAX_TIMEOUT_SECONDS

See Also:

• Constant Field Values

allowGrowing

private final boolean allowGrowing

kqueueFd

private final FileDescriptor kqueueFd

changeList

private final KQueueEventArray changeList

eventList

private final KQueueEventArray eventList

selectStrategy

private final SelectStrategy selectStrategy

iovArray

private final IovArray iovArray

selectNowSupplier

private final IntSupplier selectNowSupplier

registrations

private final LongObjectMap<KQueueEventLoop.KQueueRegistration> registrations

cancelledRegistrations

private final Queue<KQueueEventLoop.KQueueRegistration> cancelledRegistrations

nextId

private long nextId

wakenUp

private volatile int wakenUp

ioRatio

private volatile int ioRatio

Constructor Details

KQueueEventLoop

KQueueEventLoop(EventLoopGroup parent,
 Executor executor,
 int maxEvents,
 SelectStrategy strategy,
 RejectedExecutionHandler rejectedExecutionHandler,
 EventLoopTaskQueueFactory taskQueueFactory,
 EventLoopTaskQueueFactory tailTaskQueueFactory)

Method Details

newTaskQueue

private static Queue<Runnable> newTaskQueue(EventLoopTaskQueueFactory queueFactory)

generateNextId

private long generateNextId()

processCancelledRegistrations

private void processCancelledRegistrations()

add

KQueueEventLoop.KQueueRegistration add(AbstractKQueueChannel ch)

cleanArray

IovArray cleanArray()

Return a cleared IovArray that can be used for writes in this EventLoop.

wakeup

protected void wakeup(boolean inEventLoop)

Overrides:

wakeup in class SingleThreadEventExecutor

wakeup

private void wakeup()

kqueueWait

private int kqueueWait(boolean oldWakeup)
                throws IOException

Throws:

IOException

kqueueWaitNow

private int kqueueWaitNow()
                   throws IOException

Throws:

IOException

kqueueWait

private int kqueueWait(int timeoutSec,
 int timeoutNs)
                throws IOException

Throws:

IOException

processReady

private void processReady(int ready)

run

protected void run()

Description copied from class: SingleThreadEventExecutor

Run the tasks in the SingleThreadEventExecutor.taskQueue

Specified by:

run in class SingleThreadEventExecutor

newTaskQueue

protected Queue<Runnable> newTaskQueue(int maxPendingTasks)

Description copied from class: SingleThreadEventExecutor

Create a new Queue which will holds the tasks to execute. This default implementation will return a LinkedBlockingQueue but if your sub-class of SingleThreadEventExecutor will not do any blocking calls on the this Queue it may make sense to @Override this and return some more performant implementation that does not support blocking operations at all.

Overrides:

newTaskQueue in class SingleThreadEventExecutor

newTaskQueue0

private static Queue<Runnable> newTaskQueue0(int maxPendingTasks)

getIoRatio

public int getIoRatio()

Returns the percentage of the desired amount of time spent for I/O in the event loop.

setIoRatio

public void setIoRatio(int ioRatio)

Sets the percentage of the desired amount of time spent for I/O in the event loop. The default value is 50, which means the event loop will try to spend the same amount of time for I/O as for non-I/O tasks.

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.

cleanup

protected void cleanup()

Description copied from class: SingleThreadEventExecutor

Do nothing, sub-classes may override

Overrides:

cleanup in class SingleThreadEventExecutor

closeAll

private void closeAll()

handleLoopException

private static void handleLoopException(Throwable t)