Package 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-orientdb.com)

Constructor Summary

Constructors

Constructor	Description
OPartitionedLockManager()
OPartitionedLockManager(boolean useSpinLock, boolean useScalableRWLock)

Method Summary

Modifier and Type	Method	Description
Lock	acquireExclusiveLock(int value)
Lock	acquireExclusiveLock(long value)
Lock	acquireExclusiveLock(T value)
Lock[]	acquireExclusiveLocksInBatch(int[] values)
Lock[]	acquireExclusiveLocksInBatch(Collection<T> values)
final Lock[]	acquireExclusiveLocksInBatch(T... value)
Lock	acquireSharedLock(int value)
Lock	acquireSharedLock(long value)
Lock	acquireSharedLock(T value)
final Lock[]	acquireSharedLocksInBatch(T... value)
void	releaseExclusiveLock(int value)
void	releaseExclusiveLock(long value)
void	releaseExclusiveLock(T value)
void	releaseSharedLock(int value)
void	releaseSharedLock(long value)
void	releaseSharedLock(T value)
boolean	tryAcquireExclusiveLock(int value, long timeout)

Methods inherited from class java.lang.Object

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

Constructor Details

OPartitionedLockManager

public OPartitionedLockManager()

OPartitionedLockManager

public OPartitionedLockManager(boolean useSpinLock,
 boolean useScalableRWLock)

Method Details

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>

tryAcquireExclusiveLock

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

Throws:

InterruptedException

acquireExclusiveLocksInBatch

@SafeVarargs
public final Lock[] acquireExclusiveLocksInBatch(T... value)

Specified by:

acquireExclusiveLocksInBatch in interface OLockManager<T>

acquireSharedLocksInBatch

@SafeVarargs
public final 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>

acquireExclusiveLocksInBatch

public Lock[] acquireExclusiveLocksInBatch(int[] values)

acquireSharedLock

public Lock acquireSharedLock(long value)

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>