com.hazelcast.internal.networking.nio

Class NioThread

java.lang.Object

java.lang.Thread

com.hazelcast.internal.networking.nio.NioThread

All Implemented Interfaces:

OperationHostileThread, Runnable

public class NioThread
extends Thread
implements OperationHostileThread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
int	id

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
NioThread(String threadName, ILogger logger, ChannelErrorHandler errorHandler)
NioThread(String threadName, ILogger logger, ChannelErrorHandler errorHandler, SelectorMode selectMode, IdleStrategy idleStrategy)
NioThread(String threadName, ILogger logger, ChannelErrorHandler errorHandler, SelectorMode selectMode, Selector selector, IdleStrategy idleStrategy)

Method Summary

Modifier and Type	Method and Description
void	addTask(Runnable task) Adds a task to this NioThread without notifying the thread.
void	addTaskAndWakeup(Runnable task) Adds a task to be executed by the NioThread and wakes up the selector so that it will eventually pick up the task.
long	bytesTransceived()
long	completedTaskCount()
long	eventCount()
long	framesTransceived()
long	getEventCount() Returns the total number of selection-key events that have been processed by this thread.
Selector	getSelector() Gets the Selector
long	handleCount()
long	priorityFramesTransceived()
void	run()
void	shutdown()
String	toString()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Field Detail

id

public int id

Constructor Detail

NioThread

public NioThread(String threadName,
                 ILogger logger,
                 ChannelErrorHandler errorHandler)

NioThread

public NioThread(String threadName,
                 ILogger logger,
                 ChannelErrorHandler errorHandler,
                 SelectorMode selectMode,
                 IdleStrategy idleStrategy)

NioThread

public NioThread(String threadName,
                 ILogger logger,
                 ChannelErrorHandler errorHandler,
                 SelectorMode selectMode,
                 Selector selector,
                 IdleStrategy idleStrategy)

Method Detail

bytesTransceived

public long bytesTransceived()

framesTransceived

public long framesTransceived()

priorityFramesTransceived

public long priorityFramesTransceived()

handleCount

public long handleCount()

eventCount

public long eventCount()

completedTaskCount

public long completedTaskCount()

getSelector

public Selector getSelector()

Gets the Selector

Returns:

the Selector

getEventCount

public long getEventCount()

Returns the total number of selection-key events that have been processed by this thread.

Returns:

total number of selection-key events.

addTask

public void addTask(Runnable task)

Adds a task to this NioThread without notifying the thread.

Parameters:

task - the task to add

Throws:

NullPointerException - if task is null

addTaskAndWakeup

public void addTaskAndWakeup(Runnable task)

Adds a task to be executed by the NioThread and wakes up the selector so that it will eventually pick up the task.

Parameters:

task - the task to add.

Throws:

NullPointerException - if task is null

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

shutdown

public void shutdown()

toString

public String toString()

Overrides:

toString in class Thread