com.hazelcast.internal.networking.spinning

Class SpinningEventLoopGroup

java.lang.Object

com.hazelcast.internal.networking.spinning.SpinningEventLoopGroup

All Implemented Interfaces:

EventLoopGroup

public class SpinningEventLoopGroup
extends Object
implements EventLoopGroup

A EventLoopGroup 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
SpinningEventLoopGroup(LoggingService loggingService, MetricsRegistry metricsRegistry, ChannelErrorHandler errorHandler, ChannelInitializer channelInitializer, String hzName)

Method Summary

Modifier and Type	Method and Description
void	register(Channel channel) Registers a channel at this EventLoopGroup.
void	shutdown() Shuts down this EventLoopGroup.
void	start() Starts this EventLoopGroup.

Methods inherited from class java.lang.Object

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

Constructor Detail

SpinningEventLoopGroup

public SpinningEventLoopGroup(LoggingService loggingService,
                              MetricsRegistry metricsRegistry,
                              ChannelErrorHandler errorHandler,
                              ChannelInitializer channelInitializer,
                              String hzName)

Method Detail

register

public void register(Channel channel)

Description copied from interface: EventLoopGroup

Registers a channel at this EventLoopGroup. Every Channel should be registered at at most 1 EventLoopGroup and it is very unlikely that during the lifespan of the Channel, it will change its EventLoopGroup.

Specified by:

register in interface EventLoopGroup

Parameters:

channel - the channel to register.

start

public void start()

Description copied from interface: EventLoopGroup

Starts this EventLoopGroup.

Specified by:

start in interface EventLoopGroup

shutdown

public void shutdown()

Description copied from interface: EventLoopGroup

Shuts down this EventLoopGroup.

Specified by:

shutdown in interface EventLoopGroup