org.infinispan.util.concurrent.locks.impl

Class NoOpPendingLockManager

java.lang.Object

org.infinispan.util.concurrent.locks.impl.NoOpPendingLockManager

All Implemented Interfaces:

PendingLockManager

public class NoOpPendingLockManager
extends Object
implements PendingLockManager

An PendingLockManager implementation that does nothing.

Since:

8.0

Author:

Pedro Ruivo

Method Summary

Modifier and Type	Method and Description
long	awaitPendingTransactionsForAllKeys(TxInvocationContext<?> ctx, Collection<Object> keys, long time, TimeUnit unit) It waits for any transaction with older topology id to complete that may have the lock for any key in keys acquired.
long	awaitPendingTransactionsForKey(TxInvocationContext<?> ctx, Object key, long time, TimeUnit unit) It waits for any transaction with older topology id to complete that may have the lock for key acquired.
PendingLockPromise	checkPendingTransactionsForKey(TxInvocationContext<?> ctx, Object key, long time, TimeUnit unit) Same as PendingLockManager.awaitPendingTransactionsForKey(TxInvocationContext, Object, long, TimeUnit) but non-blocking.
PendingLockPromise	checkPendingTransactionsForKeys(TxInvocationContext<?> ctx, Collection<Object> keys, long time, TimeUnit unit) Same as PendingLockManager.awaitPendingTransactionsForAllKeys(TxInvocationContext, Collection, long, TimeUnit) but non-blocking.
static NoOpPendingLockManager	getInstance()

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static NoOpPendingLockManager getInstance()

checkPendingTransactionsForKey

public PendingLockPromise checkPendingTransactionsForKey(TxInvocationContext<?> ctx,
                                                         Object key,
                                                         long time,
                                                         TimeUnit unit)

Description copied from interface: PendingLockManager

Same as PendingLockManager.awaitPendingTransactionsForKey(TxInvocationContext, Object, long, TimeUnit) but non-blocking.

Multiple invocations with the same transaction returns the same PendingLockPromise. For cleanup purposes, PendingLockManager.awaitPendingTransactionsForKey(TxInvocationContext, Object, long, TimeUnit) must be invoked afterwards.

Specified by:

checkPendingTransactionsForKey in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

key - the key to check.

time - timeout.

unit - TimeUnit of time.

Returns:

a PendingLockPromise.

checkPendingTransactionsForKeys

public PendingLockPromise checkPendingTransactionsForKeys(TxInvocationContext<?> ctx,
                                                          Collection<Object> keys,
                                                          long time,
                                                          TimeUnit unit)

Description copied from interface: PendingLockManager

Same as PendingLockManager.awaitPendingTransactionsForAllKeys(TxInvocationContext, Collection, long, TimeUnit) but non-blocking.

Multiple invocations with the same transaction returns the same PendingLockPromise. For cleanup purposes, PendingLockManager.awaitPendingTransactionsForAllKeys(TxInvocationContext, Collection, long, TimeUnit) must be invoked afterwards.

Specified by:

checkPendingTransactionsForKeys in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

keys - the keys to check.

time - timeout.

unit - TimeUnit of time.

Returns:

a PendingLockPromise.

awaitPendingTransactionsForKey

public long awaitPendingTransactionsForKey(TxInvocationContext<?> ctx,
                                           Object key,
                                           long time,
                                           TimeUnit unit)
                                    throws InterruptedException

Description copied from interface: PendingLockManager

It waits for any transaction with older topology id to complete that may have the lock for key acquired.

Specified by:

awaitPendingTransactionsForKey in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

key - the key to check.

time - timeout.

unit - TimeUnit of time.

Returns:

the remaining timeout.

Throws:

InterruptedException - if the thread is interrupted while waiting.

awaitPendingTransactionsForAllKeys

public long awaitPendingTransactionsForAllKeys(TxInvocationContext<?> ctx,
                                               Collection<Object> keys,
                                               long time,
                                               TimeUnit unit)
                                        throws InterruptedException

Description copied from interface: PendingLockManager

It waits for any transaction with older topology id to complete that may have the lock for any key in keys acquired.

Specified by:

awaitPendingTransactionsForAllKeys in interface PendingLockManager

Parameters:

ctx - the TxInvocationContext.

keys - the keys to check.

time - timeout.

unit - TimeUnit of time.

Returns:

the remaining timeout.

Throws:

InterruptedException - if the thread is interrupted while waiting.