com.hazelcast.internal.networking.nonblocking

Class NonBlockingIOThread

java.lang.Object

java.lang.Thread

com.hazelcast.internal.networking.nonblocking.NonBlockingIOThread

All Implemented Interfaces:

OperationHostileThread, Runnable

public class NonBlockingIOThread
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
NonBlockingIOThread(String threadName, ILogger logger, IOOutOfMemoryHandler oomeHandler)
NonBlockingIOThread(String threadName, ILogger logger, IOOutOfMemoryHandler oomeHandler, SelectorMode selectMode)
NonBlockingIOThread(String threadName, ILogger logger, IOOutOfMemoryHandler oomeHandler, SelectorMode selectMode, Selector selector)

Method Summary

Modifier and Type	Method and Description
void	addTask(Runnable task) Adds a task to this NonBlockingIOThread without notifying the thread.
void	addTaskAndWakeup(Runnable task) Adds a task to be executed by the NonBlockingIOThread and wakes up the selector so that it will eventually pick up the task.
long	getEventCount() Returns the total number of selection-key events that have been processed by this thread.
IOOutOfMemoryHandler	getOomeHandler()
Selector	getSelector() Gets the Selector
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

NonBlockingIOThread

public NonBlockingIOThread(String threadName,
                           ILogger logger,
                           IOOutOfMemoryHandler oomeHandler)

NonBlockingIOThread

public NonBlockingIOThread(String threadName,
                           ILogger logger,
                           IOOutOfMemoryHandler oomeHandler,
                           SelectorMode selectMode)

NonBlockingIOThread

public NonBlockingIOThread(String threadName,
                           ILogger logger,
                           IOOutOfMemoryHandler oomeHandler,
                           SelectorMode selectMode,
                           Selector selector)

Method Detail

getSelector

public final Selector getSelector()

Gets the Selector

Returns:

the Selector

getOomeHandler

public IOOutOfMemoryHandler getOomeHandler()

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 final void addTask(Runnable task)

Adds a task to this NonBlockingIOThread 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 NonBlockingIOThread 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 final void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

shutdown

public final void shutdown()

toString

public String toString()

Overrides:

toString in class Thread