com.hazelcast.spi.impl.sequence

Class FailFastCallIdSequence

java.lang.Object

com.hazelcast.spi.impl.sequence.AbstractCallIdSequence

com.hazelcast.spi.impl.sequence.FailFastCallIdSequence

All Implemented Interfaces:

CallIdSequence

public class FailFastCallIdSequence
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.

Constructor Summary

Constructors

Constructor and Description
FailFastCallIdSequence(int maxConcurrentInvocations)

Method Summary

Modifier and Type	Method and Description
protected void	handleNoSpaceLeft()

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

complete, 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

FailFastCallIdSequence

public FailFastCallIdSequence(int maxConcurrentInvocations)

Method Detail

handleNoSpaceLeft

protected void handleNoSpaceLeft()

Specified by:

handleNoSpaceLeft in class AbstractCallIdSequence