com.hazelcast.nio.tcp.nonblocking

Class NonBlockingIOThread

java.lang.Object

java.lang.Thread

com.hazelcast.nio.tcp.nonblocking.NonBlockingIOThread

All Implemented Interfaces:

OperationHostileThread, Runnable

Direct Known Subclasses:

ClientNonBlockingOutputThread

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 inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
NonBlockingIOThread(ThreadGroup threadGroup, String threadName, ILogger logger, NonBlockingIOThreadOutOfMemoryHandler oomeHandler)
NonBlockingIOThread(ThreadGroup threadGroup, String threadName, ILogger logger, NonBlockingIOThreadOutOfMemoryHandler oomeHandler, boolean selectNow)
NonBlockingIOThread(ThreadGroup threadGroup, String threadName, ILogger logger, NonBlockingIOThreadOutOfMemoryHandler oomeHandler, boolean selectNow, Selector selector)

Method Summary

Methods

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.
Selector	getSelector() Gets the Selector
protected void	handleSelectionKey(SelectionKey sk)
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

Constructor Detail

NonBlockingIOThread

public NonBlockingIOThread(ThreadGroup threadGroup,
                   String threadName,
                   ILogger logger,
                   NonBlockingIOThreadOutOfMemoryHandler oomeHandler)

NonBlockingIOThread

public NonBlockingIOThread(ThreadGroup threadGroup,
                   String threadName,
                   ILogger logger,
                   NonBlockingIOThreadOutOfMemoryHandler oomeHandler,
                   boolean selectNow)

NonBlockingIOThread

public NonBlockingIOThread(ThreadGroup threadGroup,
                   String threadName,
                   ILogger logger,
                   NonBlockingIOThreadOutOfMemoryHandler oomeHandler,
                   boolean selectNow,
                   Selector selector)

Method Detail

getSelector

public final 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 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

handleSelectionKey

protected void handleSelectionKey(SelectionKey sk)

shutdown

public final void shutdown()

toString

public String toString()

Overrides:

toString in class Thread