com.hazelcast.spi.impl.operationservice.impl

Class InboundResponseHandlerSupplier

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.InboundResponseHandlerSupplier

All Implemented Interfaces:

MetricsProvider, Supplier<Consumer<Packet>>

public class InboundResponseHandlerSupplier
extends Object
implements MetricsProvider, Supplier<Consumer<Packet>>

A Supplier responsible for providing a Consumer that processes inbound responses. Depending on the GroupProperty.RESPONSE_THREAD_COUNT it will return the appropriate response handler:

1. a 'sync' response handler that doesn't offload to a different thread and processes the response on the calling (IO) thread.
2. a single threaded Packet Consumer that offloads the response processing a ResponseThread/li>
3. a multi threaded Packet Consumer that offloads the response processing to a pool of ResponseThreads.

Having multiple threads processing responses improves performance and stability of the throughput. In case of asynchronous response processing, the response is put in the responseQueue of the ResponseThread. Then the ResponseThread takes it from this responseQueue and calls a Consumer for the actual processing. The reason that the IO thread doesn't immediately deal with the response is that dealing with the response and especially notifying the invocation future can be very expensive.

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	IDLE_STRATEGY

Method Summary

Modifier and Type	Method and Description
InboundResponseHandler	backupHandler()
Consumer<Packet>	get()
static IdleStrategy	getIdleStrategy(HazelcastProperties properties, HazelcastProperty property)
void	provideMetrics(MetricsRegistry registry)
int	responseQueueSize()
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

IDLE_STRATEGY

public static final HazelcastProperty IDLE_STRATEGY

Method Detail

backupHandler

public InboundResponseHandler backupHandler()

responseQueueSize

public int responseQueueSize()

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

get

public Consumer<Packet> get()

Specified by:

get in interface Supplier<Consumer<Packet>>

start

public void start()

shutdown

public void shutdown()

getIdleStrategy

public static IdleStrategy getIdleStrategy(HazelcastProperties properties,
                                           HazelcastProperty property)