com.aerospike.client.async

Class NettyEventLoop

java.lang.Object

com.aerospike.client.async.NettyEventLoop

All Implemented Interfaces:

EventLoop

public final class NettyEventLoop
extends Object
implements EventLoop

Aerospike wrapper around netty event loop. Implements the Aerospike EventLoop interface.

Constructor Summary

Constructors

Constructor and Description
NettyEventLoop(EventPolicy policy, io.netty.channel.EventLoop eventLoop, NettyEventLoops parent, int index) Construct Aerospike event loop wrapper from netty event loop.

Method Summary

Methods

Modifier and Type	Method and Description
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.
io.netty.channel.EventLoop	get() Return netty event loop.
int	getIndex() Return event loop array index.
void	schedule(Runnable command, long delay, TimeUnit unit) Schedule execution of runnable command with delay.
void	schedule(com.aerospike.client.async.ScheduleTask task, long delay, TimeUnit unit) Schedule execution with a reusable ScheduleTask.

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyEventLoop

public NettyEventLoop(EventPolicy policy,
              io.netty.channel.EventLoop eventLoop,
              NettyEventLoops parent,
              int index)

Construct Aerospike event loop wrapper from netty event loop.

Method Detail

get

public io.netty.channel.EventLoop get()

Return netty event loop.

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.

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.

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