com.orientechnologies.common.concur.lock

Class OComparableLockManager<T extends Comparable>

java.lang.Object

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

public class OComparableLockManager<T extends Comparable>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OComparableLockManager.LOCK

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentSkipListMap<T,com.orientechnologies.common.concur.lock.OComparableLockManager.CountableLock>	map

Constructor Summary

Constructors

Constructor and Description
OComparableLockManager(boolean iEnabled, int iAcquireTimeout)
OComparableLockManager(boolean iEnabled, int iAcquireTimeout, int concurrencyLevel)

Method Summary

Modifier and Type	Method and Description
void	acquireExclusiveLock(T key)
void	acquireLock(T iResourceId, OComparableLockManager.LOCK iLockType)
void	acquireLock(T iResourceId, OComparableLockManager.LOCK iLockType, long iTimeout)
void	acquireSharedLock(T key)
int	getCountCurrentLocks()
protected T	getImmutableResourceId(T iResourceId)
void	releaseExclusiveLock(T key)
void	releaseLock(Object iRequester, T iResourceId, OComparableLockManager.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 Detail

map

protected final ConcurrentSkipListMap<T extends Comparable,com.orientechnologies.common.concur.lock.OComparableLockManager.CountableLock> map

Constructor Detail

OComparableLockManager

public OComparableLockManager(boolean iEnabled,
                              int iAcquireTimeout)

OComparableLockManager

public OComparableLockManager(boolean iEnabled,
                              int iAcquireTimeout,
                              int concurrencyLevel)

Method Detail

acquireSharedLock

public void acquireSharedLock(T key)

releaseSharedLock

public void releaseSharedLock(T key)

acquireExclusiveLock

public void acquireExclusiveLock(T key)

releaseExclusiveLock

public void releaseExclusiveLock(T key)

acquireLock

public void acquireLock(T iResourceId,
                        OComparableLockManager.LOCK iLockType)

acquireLock

public void acquireLock(T iResourceId,
                        OComparableLockManager.LOCK iLockType,
                        long iTimeout)

releaseLock

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

Throws:

OLockException

getCountCurrentLocks

public int getCountCurrentLocks()

getImmutableResourceId

protected T getImmutableResourceId(T iResourceId)