OPartitionedLockManager (OrientDB 2.2.1-SNAPSHOT API)

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)

Field Summary

Fields
Modifier and Type Field and Description

static Comparator COMPARATOR

static int MASK

Fields
Modifier and Type	Field and Description
`static Comparator`	`COMPARATOR`
`static int`	`MASK`

Constructor Summary

Constructors
Constructor and Description

OPartitionedLockManager()

OPartitionedLockManager(boolean useSpinLock)

Constructors
Constructor and Description
`OPartitionedLockManager()`
`OPartitionedLockManager(boolean useSpinLock)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`Lock`	`acquireExclusiveLock(int value)`
`Lock`	`acquireExclusiveLock(long value)`
`Lock`	`acquireExclusiveLock(T value)`
`void`	`acquireExclusiveLocksInBatch(Collection<T> values)`
`Lock[]`	`acquireExclusiveLocksInBatch(T... value)`
`Lock`	`acquireSharedLock(int value)`
`Lock`	`acquireSharedLock(long value)`
`Lock`	`acquireSharedLock(T value)`
`Lock[]`	`acquireSharedLocksInBatch(T... value)`
`static <T> Collection<T>`	`getOrderedValues(Collection<T> values)`
`static <T> T[]`	`getOrderedValues(T[] values)`
`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

Field Detail

MASK
```
public static final int MASK
```

COMPARATOR

public static final Comparator COMPARATOR

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)

acquireExclusiveLocksInBatch
```
public void 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)
```

getOrderedValues

public static <T> T[] getOrderedValues(T[] values)

getOrderedValues

public static <T> Collection<T> getOrderedValues(Collection<T> values)

Class OPartitionedLockManager<T>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

MASK

COMPARATOR

Constructor Detail

OPartitionedLockManager

OPartitionedLockManager

Method Detail

shuffleHashCode

acquireExclusiveLock

acquireExclusiveLock

acquireExclusiveLock

lockAllExclusive

unlockAllExclusive

tryAcquireExclusiveLock

acquireExclusiveLocksInBatch

acquireSharedLocksInBatch

acquireExclusiveLocksInBatch

acquireSharedLock

tryAcquireSharedLock

acquireSharedLock

acquireSharedLock

releaseSharedLock

releaseSharedLock

releaseSharedLock

releaseExclusiveLock

releaseExclusiveLock

releaseExclusiveLock

releaseLock

getOrderedValues

getOrderedValues