org.infinispan.util.concurrent.locks.containers

Class OwnableReentrantStripedLockContainer

java.lang.Object

org.infinispan.util.concurrent.locks.containers.AbstractLockContainer<L>

org.infinispan.util.concurrent.locks.containers.AbstractStripedLockContainer<OwnableReentrantLock>

org.infinispan.util.concurrent.locks.containers.OwnableReentrantStripedLockContainer

All Implemented Interfaces:

LockContainer<OwnableReentrantLock>

@ThreadSafe
public class OwnableReentrantStripedLockContainer
extends AbstractStripedLockContainer<OwnableReentrantLock>

A LockContainer that holds OwnableReentrantLocks.

Since:

4.0

Author:

Manik Surtani (manik@jboss.org)

See Also:

ReentrantStripedLockContainer, OwnableReentrantLock

Constructor Summary

Constructors

Constructor and Description
OwnableReentrantStripedLockContainer(int concurrencyLevel) Creates a new LockContainer which uses a certain number of shared locks across all elements that need to be locked.

Method Summary

Methods

Modifier and Type	Method and Description
OwnableReentrantLock	getLock(Object object)
protected Log	getLog()
int	getNumLocksHeld()
protected void	initLocks(int numLocks)
boolean	isLocked(Object object)
protected void	lock(OwnableReentrantLock lock, Object lockOwner)
boolean	ownsLock(Object object, Object owner) Tests if a give owner owns a lock on a specified object.
int	size()
String	toString()
protected boolean	tryLock(OwnableReentrantLock lock, long timeout, TimeUnit unit, Object lockOwner)
protected void	unlock(OwnableReentrantLock l, Object owner)

Methods inherited from class org.infinispan.util.concurrent.locks.containers.AbstractStripedLockContainer

acquireLock, getLockId, releaseLock

Methods inherited from class org.infinispan.util.concurrent.locks.containers.AbstractLockContainer

safeRelease

Methods inherited from class java.lang.Object

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

Constructor Detail

OwnableReentrantStripedLockContainer

public OwnableReentrantStripedLockContainer(int concurrencyLevel)

Creates a new LockContainer which uses a certain number of shared locks across all elements that need to be locked.

Parameters:

concurrencyLevel - concurrency level for number of stripes to create. Stripes are created in powers of two, with a minimum of concurrencyLevel created.

Method Detail

getLog

protected Log getLog()

Specified by:

getLog in class AbstractLockContainer<OwnableReentrantLock>

initLocks

protected void initLocks(int numLocks)

Specified by:

initLocks in class AbstractStripedLockContainer<OwnableReentrantLock>

getLock

public final OwnableReentrantLock getLock(Object object)

Parameters:

object - object

Returns:

the lock for a specific object. May be null if the object is not locked, but may also be an unlocked lock.

ownsLock

public final boolean ownsLock(Object object,
               Object owner)

Description copied from interface: LockContainer

Tests if a give owner owns a lock on a specified object.

Parameters:

object - object to check

owner - owner to test

Returns:

true if owner owns lock, false otherwise

isLocked

public final boolean isLocked(Object object)

Parameters:

object - object

Returns:

true if an object is locked, false otherwise

getNumLocksHeld

public final int getNumLocksHeld()

Returns:

number of locks held

toString

public String toString()

Overrides:

toString in class Object

size

public int size()

Returns:

the size of the shared lock pool

tryLock

protected boolean tryLock(OwnableReentrantLock lock,
              long timeout,
              TimeUnit unit,
              Object lockOwner)
                   throws InterruptedException

Specified by:

tryLock in class AbstractLockContainer<OwnableReentrantLock>

Throws:

InterruptedException

lock

protected void lock(OwnableReentrantLock lock,
        Object lockOwner)

Specified by:

lock in class AbstractLockContainer<OwnableReentrantLock>

unlock

protected void unlock(OwnableReentrantLock l,
          Object owner)

Specified by:

unlock in class AbstractLockContainer<OwnableReentrantLock>