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. This implementation works better than OPartitionedLockManager when running distributed because there is no way to cause a deadlock based on different keys.

Author:

Luca Garulli

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OOneEntryPerKeyLockManager.LOCK

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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	lockAllExclusive()
void	releaseExclusiveLock(T key)
void	releaseLock(Object iRequester, T iResourceId, OOneEntryPerKeyLockManager.LOCK iLockType)
void	releaseSharedLock(T key)
void	unlockAllExclusive()

Methods inherited from class java.lang.Object

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

Field Detail

map

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

Constructor Detail

OOneEntryPerKeyLockManager

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

OOneEntryPerKeyLockManager

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

Method Detail

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>

lockAllExclusive

public void lockAllExclusive()

Specified by:

lockAllExclusive in interface OLockManager<T>

unlockAllExclusive

public void unlockAllExclusive()

Specified by:

unlockAllExclusive in interface OLockManager<T>

getCountCurrentLocks

public int getCountCurrentLocks()

getImmutableResourceId

protected T getImmutableResourceId(T iResourceId)

acquireLockInBatch

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