com.hazelcast.internal.networking.spinning

Class SpinningIOThreadingModel

java.lang.Object

com.hazelcast.internal.networking.spinning.SpinningIOThreadingModel

All Implemented Interfaces:

IOThreadingModel

public class SpinningIOThreadingModel
extends Object
implements IOThreadingModel

A IOThreadingModel that uses (busy) spinning on the SocketChannels to see if there is something to read or write. Currently there are 2 threads spinning:

1. 1 thread spinning on all SocketChannels for reading
2. 1 thread spinning on all SocketChannels for writing

In the future we need to play with this a lot more. 1 thread should be able to saturate a 40GbE connection, but that currently doesn't work for us. So I guess our IO threads are doing too much stuff not relevant like writing the Frames to bytebuffers or converting the bytebuffers to Frames. This is an experimental feature and disabled by default.

Constructor Summary

Constructors

Constructor and Description
SpinningIOThreadingModel(LoggingService loggingService, HazelcastThreadGroup hazelcastThreadGroup, IOOutOfMemoryHandler oomeHandler, SocketWriterInitializer socketWriterInitializer, SocketReaderInitializer socketReaderInitializer)

Method Summary

Modifier and Type	Method and Description
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	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

SpinningIOThreadingModel

public SpinningIOThreadingModel(LoggingService loggingService,
                                HazelcastThreadGroup hazelcastThreadGroup,
                                IOOutOfMemoryHandler oomeHandler,
                                SocketWriterInitializer socketWriterInitializer,
                                SocketReaderInitializer socketReaderInitializer)

Method Detail

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)}

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

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.

start

public void start()

Description copied from interface: IOThreadingModel

Starts the IOThreadingModel.

Specified by:

start in interface IOThreadingModel

shutdown

public void shutdown()

Description copied from interface: IOThreadingModel

Shuts down the IOThreadingModel.

Specified by:

shutdown in interface IOThreadingModel