com.aerospike.client.async

Class NioEventLoop

java.lang.Object

java.lang.Thread

com.aerospike.client.async.NioEventLoop

All Implemented Interfaces:

EventLoop, Runnable

public final class NioEventLoop
extends Thread
implements EventLoop

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
NioEventLoop(EventPolicy policy, SelectorProvider provider, int index)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
static ByteBuffer	createByteBuffer(int size)
com.aerospike.client.async.EventState	createState() For internal use only.
void	execute(com.aerospike.client.cluster.Cluster cluster, com.aerospike.client.async.AsyncCommand command) Execute async command.
void	execute(Runnable command) Schedule execution of runnable command on event loop.
ByteBuffer	getByteBuffer()
int	getIndex() Return event loop array index.
void	putByteBuffer(ByteBuffer byteBuffer)
void	run()
void	schedule(Runnable command, long delay, TimeUnit unit) Schedule execution of runnable command with delay in milliseconds.
void	schedule(com.aerospike.client.async.ScheduleTask task, long delay, TimeUnit unit) Schedule execution with a reusable ScheduleTask.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

NioEventLoop

public NioEventLoop(EventPolicy policy,
            SelectorProvider provider,
            int index)
             throws IOException

Throws:

IOException

Method Detail

execute

public void execute(com.aerospike.client.cluster.Cluster cluster,
           com.aerospike.client.async.AsyncCommand command)

Execute async command. Execute immediately if in event loop. Otherwise, place command on event loop queue.

Specified by:

execute in interface EventLoop

execute

public void execute(Runnable command)

Schedule execution of runnable command on event loop. Command is placed on event loop queue and is never executed directly.

Specified by:

execute in interface EventLoop

schedule

public void schedule(Runnable command,
            long delay,
            TimeUnit unit)

Schedule execution of runnable command with delay in milliseconds.

Specified by:

schedule in interface EventLoop

schedule

public void schedule(com.aerospike.client.async.ScheduleTask task,
            long delay,
            TimeUnit unit)

Schedule execution with a reusable ScheduleTask. Saves memory allocation for repeatedly scheduled task.

Specified by:

schedule in interface EventLoop

getIndex

public int getIndex()

Return event loop array index.

Specified by:

getIndex in interface EventLoop

createState

public com.aerospike.client.async.EventState createState()

For internal use only.

Specified by:

createState in interface EventLoop

createByteBuffer

public static ByteBuffer createByteBuffer(int size)

getByteBuffer

public ByteBuffer getByteBuffer()

putByteBuffer

public void putByteBuffer(ByteBuffer byteBuffer)

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

close

public void close()