org.infinispan.util.concurrent.locks.containers
Class ReentrantStripedLockContainer

java.lang.Object
  org.infinispan.util.concurrent.locks.containers.AbstractLockContainer<L>
      org.infinispan.util.concurrent.locks.containers.AbstractStripedLockContainer<ReentrantLock>
          org.infinispan.util.concurrent.locks.containers.ReentrantStripedLockContainer

All Implemented Interfaces:

LockContainer<ReentrantLock>

@ThreadSafe
public class ReentrantStripedLockContainer
extends AbstractStripedLockContainer<ReentrantLock>

A LockContainer that holds ReentrantLocks

Since:

4.0

Author:

Manik Surtani (manik@jboss.org)

See Also:

OwnableReentrantStripedLockContainer

Constructor Summary

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

Method Summary

ReentrantLock	getLock(Object object)
int	getNumLocksHeld()
protected void	initLocks(int numLocks)
boolean	isLocked(Object object)
boolean	ownsLock(Object object, Object ignored) Tests if a give owner owns a lock on a specified object.
int	size()
String	toString()
protected boolean	tryLock(ReentrantLock lock, long timeout, TimeUnit unit, Object unused)
protected void	unlock(ReentrantLock l, Object unused)

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

ReentrantStripedLockContainer

public ReentrantStripedLockContainer(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

initLocks

protected void initLocks(int numLocks)

Specified by:

initLocks in class AbstractStripedLockContainer<ReentrantLock>

getLock

public final ReentrantLock getLock(Object object)

Parameters:

object - object

Returns:

the lock for a specific object

getNumLocksHeld

public final int getNumLocksHeld()

Returns:

number of locks held

size

public int size()

Returns:

the size of the shared lock pool

ownsLock

public final boolean ownsLock(Object object,
                              Object ignored)

Description copied from interface: LockContainer

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

Parameters:

object - object to check

ignored - 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

toString

public String toString()

Overrides:

toString in class Object

unlock

protected void unlock(ReentrantLock l,
                      Object unused)

Specified by:

unlock in class AbstractLockContainer<ReentrantLock>

tryLock

protected boolean tryLock(ReentrantLock lock,
                          long timeout,
                          TimeUnit unit,
                          Object unused)
                   throws InterruptedException

Specified by:

tryLock in class AbstractLockContainer<ReentrantLock>

Throws:

InterruptedException