com.hazelcast.internal.networking.nonblocking

Class NonBlockingIOThreadingModel

java.lang.Object

com.hazelcast.internal.networking.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(LoggingService loggingService, MetricsRegistry metricsRegistry, String hzName, IOOutOfMemoryHandler oomeHandler, int inputThreadCount, int outputThreadCount, int balanceIntervalSeconds, SocketWriterInitializer socketWriterInitializer, SocketReaderInitializer socketReaderInitializer)

Method Summary

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(SocketConnection connection) Creates a new SocketReader for the given connection.
SocketWriter	newSocketWriter(SocketConnection connection) Creates a new SocketWriter for the given connection.
void	onConnectionAdded(SocketConnection connection) Is called when a connection is added.
void	onConnectionRemoved(SocketConnection 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(LoggingService loggingService,
                                   MetricsRegistry metricsRegistry,
                                   String hzName,
                                   IOOutOfMemoryHandler oomeHandler,
                                   int inputThreadCount,
                                   int outputThreadCount,
                                   int balanceIntervalSeconds,
                                   SocketWriterInitializer socketWriterInitializer,
                                   SocketReaderInitializer socketReaderInitializer)

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.

Specified by:

start in interface IOThreadingModel

onConnectionAdded

public void onConnectionAdded(SocketConnection 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(SocketConnection 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.

Specified by:

shutdown in interface IOThreadingModel

newSocketWriter

public SocketWriter newSocketWriter(SocketConnection 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(SocketConnection 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