com.orientechnologies.common.concur.lock

Class OPartitionedLockManager<T>

java.lang.Object

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

All Implemented Interfaces:

OLockManager<T>

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

Lock manager implementation that uses multipel partitions to increase the level of concurrency without having to keep one entry per locked key, like for OOneEntryPerKeyLockManager implementation.

Since:

8/11/14

Author:

Andrey Lomakin (a.lomakin-at-orientechnologies.com)

Constructor Summary

Constructors

Constructor and Description
OPartitionedLockManager()
OPartitionedLockManager(boolean useSpinLock)

Method Summary

Modifier and Type	Method and Description
Lock	acquireExclusiveLock(int value)
Lock	acquireExclusiveLock(long value)
Lock	acquireExclusiveLock(T value)
Lock[]	acquireExclusiveLocksInBatch(Collection<T> values)
Lock[]	acquireExclusiveLocksInBatch(T... value)
Lock	acquireSharedLock(int value)
Lock	acquireSharedLock(long value)
Lock	acquireSharedLock(T value)
Lock[]	acquireSharedLocksInBatch(T... value)
void	lockAllExclusive()
void	releaseExclusiveLock(int value)
void	releaseExclusiveLock(long value)
void	releaseExclusiveLock(T value)
void	releaseLock(Lock lock)
void	releaseSharedLock(int value)
void	releaseSharedLock(long value)
void	releaseSharedLock(T value)
static int	shuffleHashCode(int h)
boolean	tryAcquireExclusiveLock(T value, long timeout)
boolean	tryAcquireSharedLock(T value, long timeout)
void	unlockAllExclusive()

Methods inherited from class java.lang.Object

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

Constructor Detail

OPartitionedLockManager

public OPartitionedLockManager()

OPartitionedLockManager

public OPartitionedLockManager(boolean useSpinLock)

Method Detail

shuffleHashCode

public static int shuffleHashCode(int h)

acquireExclusiveLock

public Lock acquireExclusiveLock(long value)

acquireExclusiveLock

public Lock acquireExclusiveLock(int value)

acquireExclusiveLock

public Lock acquireExclusiveLock(T value)

Specified by:

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

tryAcquireExclusiveLock

public boolean tryAcquireExclusiveLock(T value,
                                       long timeout)
                                throws InterruptedException

Throws:

InterruptedException

acquireExclusiveLocksInBatch

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

Specified by:

acquireExclusiveLocksInBatch in interface OLockManager<T>

acquireSharedLocksInBatch

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

Specified by:

acquireSharedLocksInBatch in interface OLockManager<T>

acquireExclusiveLocksInBatch

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

Specified by:

acquireExclusiveLocksInBatch in interface OLockManager<T>

acquireSharedLock

public Lock acquireSharedLock(long value)

tryAcquireSharedLock

public boolean tryAcquireSharedLock(T value,
                                    long timeout)
                             throws InterruptedException

Throws:

InterruptedException

acquireSharedLock

public Lock acquireSharedLock(int value)

acquireSharedLock

public Lock acquireSharedLock(T value)

Specified by:

acquireSharedLock in interface OLockManager<T>

releaseSharedLock

public void releaseSharedLock(int value)

releaseSharedLock

public void releaseSharedLock(long value)

releaseSharedLock

public void releaseSharedLock(T value)

Specified by:

releaseSharedLock in interface OLockManager<T>

releaseExclusiveLock

public void releaseExclusiveLock(int value)

releaseExclusiveLock

public void releaseExclusiveLock(long value)

releaseExclusiveLock

public void releaseExclusiveLock(T value)

Specified by:

releaseExclusiveLock in interface OLockManager<T>

releaseLock

public void releaseLock(Lock lock)