Package com.orientechnologies.common.concur.lock

Class OOneEntryPerKeyLockManager<T>

java.lang.Object

com.orientechnologies.common.concur.lock.OOneEntryPerKeyLockManager<T>

Type Parameters:

T - Type of keys

All Implemented Interfaces:

OLockManager<T>

public class OOneEntryPerKeyLockManager<T>
extends Object
implements OLockManager<T>

Original Lock Manager implementation that uses a concurrent linked hash map to store one entry per key. This could be very expensive in case the number of locks are a lot.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	OOneEntryPerKeyLockManager.LOCK

Field Summary

Fields

Modifier and Type	Field	Description
protected final com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap<T,com.orientechnologies.common.concur.lock.OOneEntryPerKeyLockManager.CountableLock>	map

Constructor Summary

Constructors

Constructor	Description
OOneEntryPerKeyLockManager(boolean iEnabled, int iAcquireTimeout, int amountOfCachedInstances)
OOneEntryPerKeyLockManager(boolean iEnabled, int iAcquireTimeout, int concurrencyLevel, int amountOfCachedInstances)

Method Summary

Modifier and Type	Method	Description
Lock	acquireExclusiveLock(T key)
Lock[]	acquireExclusiveLocksInBatch(Collection<T> values)
Lock[]	acquireExclusiveLocksInBatch(T... values)
Lock	acquireLock(T iResourceId, OOneEntryPerKeyLockManager.LOCK iLockType)
Lock	acquireLock(T iResourceId, OOneEntryPerKeyLockManager.LOCK iLockType, long iTimeout)
protected Lock[]	acquireLockInBatch(T[] values, boolean exclusiveMode)
Lock	acquireSharedLock(T key)
Lock[]	acquireSharedLocksInBatch(T... values)
int	getCountCurrentLocks()
protected T	getImmutableResourceId(T iResourceId)
void	releaseExclusiveLock(T key)
void	releaseLock(Object iRequester, T iResourceId, OOneEntryPerKeyLockManager.LOCK iLockType)
void	releaseSharedLock(T key)

Methods inherited from class java.lang.Object

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

Field Details

map

protected final com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap<T,com.orientechnologies.common.concur.lock.OOneEntryPerKeyLockManager.CountableLock> map

Constructor Details

OOneEntryPerKeyLockManager

public OOneEntryPerKeyLockManager(boolean iEnabled,
 int iAcquireTimeout,
 int amountOfCachedInstances)

OOneEntryPerKeyLockManager

public OOneEntryPerKeyLockManager(boolean iEnabled,
 int iAcquireTimeout,
 int concurrencyLevel,
 int amountOfCachedInstances)

Method Details

acquireSharedLock

public Lock acquireSharedLock(T key)

Specified by:

acquireSharedLock in interface OLockManager<T>

releaseSharedLock

public void releaseSharedLock(T key)

Specified by:

releaseSharedLock in interface OLockManager<T>

acquireExclusiveLock

public Lock acquireExclusiveLock(T key)

Specified by:

acquireExclusiveLock in interface OLockManager<T>

releaseExclusiveLock

public void releaseExclusiveLock(T key)

Specified by:

releaseExclusiveLock in interface OLockManager<T>

acquireLock

public Lock acquireLock(T iResourceId,
 OOneEntryPerKeyLockManager.LOCK iLockType)

acquireLock

public Lock acquireLock(T iResourceId,
 OOneEntryPerKeyLockManager.LOCK iLockType,
 long iTimeout)

releaseLock

public void releaseLock(Object iRequester,
 T iResourceId,
 OOneEntryPerKeyLockManager.LOCK iLockType)
                 throws OLockException

Throws:

OLockException

acquireExclusiveLocksInBatch

public Lock[] acquireExclusiveLocksInBatch(T... values)

Specified by:

acquireExclusiveLocksInBatch in interface OLockManager<T>

acquireSharedLocksInBatch

public Lock[] acquireSharedLocksInBatch(T... values)

Specified by:

acquireSharedLocksInBatch in interface OLockManager<T>

acquireExclusiveLocksInBatch

public Lock[] acquireExclusiveLocksInBatch(Collection<T> values)

Specified by:

acquireExclusiveLocksInBatch in interface OLockManager<T>

getCountCurrentLocks

public int getCountCurrentLocks()

getImmutableResourceId

protected T getImmutableResourceId(T iResourceId)

acquireLockInBatch

protected Lock[] acquireLockInBatch(T[] values,
 boolean exclusiveMode)