com.hazelcast.spi.impl.sequence

Class CallIdSequenceWithBackpressure

java.lang.Object

com.hazelcast.spi.impl.sequence.AbstractCallIdSequence

com.hazelcast.spi.impl.sequence.CallIdSequenceWithBackpressure

All Implemented Interfaces:

CallIdSequence

public final class CallIdSequenceWithBackpressure
extends AbstractCallIdSequence

A CallIdSequence that provides backpressure by taking the number of in-flight operations into account when before creating a new call-id.

It is possible to temporarily create more concurrent invocations than the declared capacity due to:

• system operations
• the racy nature of checking if space is available and getting the next sequence.

The latter cause is not a problem since the capacity is exceeded temporarily and it isn't sustainable. So perhaps there are a few threads that at the same time see that the there is space and do a next. But any following invocation needs to wait till there is is capacity.

Constructor Summary

Constructors

Constructor and Description
CallIdSequenceWithBackpressure(int maxConcurrentInvocations, long backoffTimeoutMs)

Method Summary

Modifier and Type	Method and Description
protected void	handleNoSpaceLeft()

Methods inherited from class com.hazelcast.spi.impl.sequence.AbstractCallIdSequence

complete, concurrentInvocations, forceNext, getLastCallId, getMaxConcurrentInvocations, hasSpace, next

Methods inherited from class java.lang.Object

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

Constructor Detail

CallIdSequenceWithBackpressure

public CallIdSequenceWithBackpressure(int maxConcurrentInvocations,
                                      long backoffTimeoutMs)

Method Detail

handleNoSpaceLeft

protected void handleNoSpaceLeft()

Specified by:

handleNoSpaceLeft in class AbstractCallIdSequence