com.hazelcast.nio.tcp.nonblocking

Class NonBlockingIOThreadingModel

java.lang.Object

com.hazelcast.nio.tcp.nonblocking.NonBlockingIOThreadingModel

All Implemented Interfaces:

IOThreadingModel

public class NonBlockingIOThreadingModel
extends Object
implements IOThreadingModel

A non blocking IOThreadingModel implementation that makes use of Selector to have a limited set of io threads, handle an arbitrary number of connections. By default the NonBlockingIOThread blocks on the Selector, but it can be put in a 'selectNow' mode that makes it spinning on the selector. This is an experimental feature and will cause the io threads to run hot. For this reason, when this feature is enabled, the number of io threads should be reduced (preferably 1).

Constructor Summary

Constructors

Constructor and Description
NonBlockingIOThreadingModel(IOService ioService, LoggingService loggingService, MetricsRegistry metricsRegistry, HazelcastThreadGroup hazelcastThreadGroup)

Method Summary

Methods

Modifier and Type	Method and Description
NonBlockingIOThread[]	getInputThreads()
IOBalancer	getIOBalancer()
NonBlockingIOThread[]	getOutputThreads()
boolean	isBlocking() Tells whether or not every I/O operation on SocketChannel should block until it completes.
SocketReader	newSocketReader(TcpIpConnection connection) Creates a new SocketReader for the given connection.
SocketWriter	newSocketWriter(TcpIpConnection connection) Creates a new SocketWriter for the given connection.
void	onConnectionAdded(TcpIpConnection connection) Is called when a connection is added.
void	onConnectionRemoved(TcpIpConnection connection) Is called when a connection is removed.
void	setSelectorMode(SelectorMode mode)
void	shutdown() Shuts down the IOThreadingModel.
void	start() Starts the IOThreadingModel.

Methods inherited from class java.lang.Object

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

Constructor Detail

NonBlockingIOThreadingModel

public NonBlockingIOThreadingModel(IOService ioService,
                           LoggingService loggingService,
                           MetricsRegistry metricsRegistry,
                           HazelcastThreadGroup hazelcastThreadGroup)

Method Detail

setSelectorMode

public void setSelectorMode(SelectorMode mode)

isBlocking

public boolean isBlocking()

Description copied from interface: IOThreadingModel

Tells whether or not every I/O operation on SocketChannel should block until it completes.

Specified by:

isBlocking in interface IOThreadingModel

Returns:

true if blocking, false otherwise.

See Also:

java.nio.channels.SelectableChannel#configureBlocking(boolean)}

getInputThreads

public NonBlockingIOThread[] getInputThreads()

getOutputThreads

public NonBlockingIOThread[] getOutputThreads()

getIOBalancer

public IOBalancer getIOBalancer()

start

public void start()

Description copied from interface: IOThreadingModel

Starts the IOThreadingModel. Is called by the TcpIpConnectionManager when it starts.

Specified by:

start in interface IOThreadingModel

See Also:

TcpIpConnectionManager.start()

onConnectionAdded

public void onConnectionAdded(TcpIpConnection connection)

Description copied from interface: IOThreadingModel

Is called when a connection is added.

Specified by:

onConnectionAdded in interface IOThreadingModel

Parameters:

connection - the connection added.

onConnectionRemoved

public void onConnectionRemoved(TcpIpConnection connection)

Description copied from interface: IOThreadingModel

Is called when a connection is removed.

Specified by:

onConnectionRemoved in interface IOThreadingModel

Parameters:

connection - the connection removed.

shutdown

public void shutdown()

Description copied from interface: IOThreadingModel

Shuts down the IOThreadingModel. Is called by the TcpIpConnectionManager when it shuts down.

Specified by:

shutdown in interface IOThreadingModel

See Also:

TcpIpConnectionManager.shutdown()

newSocketWriter

public SocketWriter newSocketWriter(TcpIpConnection connection)

Description copied from interface: IOThreadingModel

Creates a new SocketWriter for the given connection.

Specified by:

newSocketWriter in interface IOThreadingModel

Parameters:

connection - the TcpIpConnection to create the SocketWriter for.

Returns:

the created SocketWriter

newSocketReader

public SocketReader newSocketReader(TcpIpConnection connection)

Description copied from interface: IOThreadingModel

Creates a new SocketReader for the given connection.

Specified by:

newSocketReader in interface IOThreadingModel

Parameters:

connection - the TcpIpConnection to create the SocketReader for.

Returns:

the created SocketReader