Package org.infinispan.util.concurrent

Class DataOperationOrderer

java.lang.Object

org.infinispan.util.concurrent.DataOperationOrderer

public class DataOperationOrderer
extends Object

Ordering construct allowing concurrent operations that wish to do operations upon the same key to wait until the most recently registered operation is complete in a non blocking way.

Since:

10.0

Author:

wburns

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DataOperationOrderer.Operation

Constructor Summary

Constructors

Constructor	Description
DataOperationOrderer()

Method Summary

Modifier and Type	Method	Description
void	completeOperation(Object key, CompletableFuture<DataOperationOrderer.Operation> registeredFuture, DataOperationOrderer.Operation operation)	Completes a given operation and removes all internal references from the orderer
CompletionStage<DataOperationOrderer.Operation>	getCurrentStage(Object key)	For testing purposes only
CompletionStage<DataOperationOrderer.Operation>	orderOn(Object key, CompletionStage<DataOperationOrderer.Operation> register)	Registers the provided Stage to be next in line to do an operation on behalf of the provided key.
int	pendingOperations()	Returns how many keys have pending operations waiting for their completion

Methods inherited from class java.lang.Object

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

Constructor Details

DataOperationOrderer

public DataOperationOrderer()

Method Details

pendingOperations

public int pendingOperations()

Returns how many keys have pending operations waiting for their completion

Returns:

number of keys with pending operations

orderOn

public CompletionStage<DataOperationOrderer.Operation> orderOn(Object key,
 CompletionStage<DataOperationOrderer.Operation> register)

Registers the provided Stage to be next in line to do an operation on behalf of the provided key. Returns a different Stage that when complete signals that this operation should continue or null if there is no wait required.

Parameters:

key - delineating identifier for an operation

register - stage to register for others to wait upon for future registrations

Returns:

stage that signals when the operation that is registering its own future may continue or null if nothing to wait on

completeOperation

public void completeOperation(Object key,
 CompletableFuture<DataOperationOrderer.Operation> registeredFuture,
 DataOperationOrderer.Operation operation)

Completes a given operation and removes all internal references from the orderer

Parameters:

key - delineating identifier for an operation

registeredFuture - previously registered future that is removed from memory as needed

operation - the type of operation

getCurrentStage

public CompletionStage<DataOperationOrderer.Operation> getCurrentStage(Object key)

For testing purposes only