Package org.infinispan.util.concurrent.locks.impl

Class PerKeyLockContainer

java.lang.Object

org.infinispan.util.concurrent.locks.impl.PerKeyLockContainer

All Implemented Interfaces:

LockContainer

public class PerKeyLockContainer
extends Object
implements LockContainer

A lock container that creates and maintains a new lock per entry.

Since:

8.0

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field	Description
protected Executor	nonBlockingExecutor

Constructor Summary

Constructors

Constructor	Description
PerKeyLockContainer()

Method Summary

Modifier and Type	Method	Description
ExtendedLockPromise	acquire(Object key, Object lockOwner, long time, TimeUnit timeUnit)
void	deadlockCheck(DeadlockChecker deadlockChecker)	It forces a deadlock checks in all existing locks.
InfinispanLock	getLock(Object key)
int	getNumLocksHeld()
boolean	isLocked(Object key)
void	release(Object key, Object lockOwner)
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

nonBlockingExecutor

protected Executor nonBlockingExecutor

Constructor Details

PerKeyLockContainer

public PerKeyLockContainer()

Method Details

acquire

public ExtendedLockPromise acquire(Object key,
 Object lockOwner,
 long time,
 TimeUnit timeUnit)

Specified by:

acquire in interface LockContainer

Parameters:

key - the key to lock.

Returns:

the lock for a specific object to be acquired. If the lock does not exists, it is created.

getLock

public InfinispanLock getLock(Object key)

Specified by:

getLock in interface LockContainer

Parameters:

key - the key to lock.

Returns:

the lock for a specific object. If the lock does not exists, it return null.

release

public void release(Object key,
 Object lockOwner)

Specified by:

release in interface LockContainer

getNumLocksHeld

public int getNumLocksHeld()

Specified by:

getNumLocksHeld in interface LockContainer

Returns:

number of locks held

isLocked

public boolean isLocked(Object key)

Specified by:

isLocked in interface LockContainer

Parameters:

key - the key to test.

Returns:

true if the key is locked, false otherwise.

size

public int size()

Specified by:

size in interface LockContainer

Returns:

the size of the shared lock pool

deadlockCheck

public void deadlockCheck(DeadlockChecker deadlockChecker)

Description copied from interface: LockContainer

It forces a deadlock checks in all existing locks.

Specified by:

deadlockCheck in interface LockContainer

toString

public String toString()

Overrides:

toString in class Object