public class SpinningIOThreadingModel extends Object implements IOThreadingModel
IOThreadingModel
that uses (busy) spinning on the SocketChannels to see if there is something
to read or write.
Currently there are 2 threads spinning:
Constructor and Description |
---|
SpinningIOThreadingModel(IOService ioService,
LoggingService loggingService,
MetricsRegistry metricsRegistry,
HazelcastThreadGroup hazelcastThreadGroup) |
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(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 |
shutdown()
Shuts down the IOThreadingModel.
|
void |
start()
Starts the IOThreadingModel.
|
public SpinningIOThreadingModel(IOService ioService, LoggingService loggingService, MetricsRegistry metricsRegistry, HazelcastThreadGroup hazelcastThreadGroup)
public boolean isBlocking()
IOThreadingModel
isBlocking
in interface IOThreadingModel
java.nio.channels.SelectableChannel#configureBlocking(boolean)}
public SocketWriter newSocketWriter(TcpIpConnection connection)
IOThreadingModel
newSocketWriter
in interface IOThreadingModel
connection
- the TcpIpConnection to create the SocketWriter for.public SocketReader newSocketReader(TcpIpConnection connection)
IOThreadingModel
newSocketReader
in interface IOThreadingModel
connection
- the TcpIpConnection to create the SocketReader for.public void onConnectionAdded(TcpIpConnection connection)
IOThreadingModel
onConnectionAdded
in interface IOThreadingModel
connection
- the connection added.public void onConnectionRemoved(TcpIpConnection connection)
IOThreadingModel
onConnectionRemoved
in interface IOThreadingModel
connection
- the connection removed.public void start()
IOThreadingModel
TcpIpConnectionManager
when it starts.start
in interface IOThreadingModel
TcpIpConnectionManager.start()
public void shutdown()
IOThreadingModel
TcpIpConnectionManager
when it shuts down.shutdown
in interface IOThreadingModel
TcpIpConnectionManager.shutdown()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.