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

Constructor Summary

Constructors

Constructor and Description
PerKeyLockContainer(int concurrencyLevel, Equivalence<Object> keyEquivalence)

Method Summary

Modifier and Type	Method and 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()
void	inject(TimeService timeService)
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

Constructor Detail

PerKeyLockContainer

public PerKeyLockContainer(int concurrencyLevel,
                           Equivalence<Object> keyEquivalence)

Method Detail

inject

public void inject(TimeService timeService)

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