Class ExclusiveReentrantLockManager

java.lang.Object

org.eclipse.rdf4j.common.concurrent.locks.ExclusiveReentrantLockManager

@InternalUseOnly
public class ExclusiveReentrantLockManager
extends Object

A simple reentrant lock that allows other threads to unlock the lock.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ExclusiveReentrantLockManager.ExclusiveReentrantLock

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final AtomicLong	activeLocks
(package private) LockMonitoring<ExclusiveReentrantLockManager.ExclusiveReentrantLock>	lockMonitoring
private static final org.slf4j.Logger	logger
(package private) final AtomicReference<Thread>	owner
private final int	waitToCollect

Constructor Summary

Constructors

Constructor	Description
ExclusiveReentrantLockManager()
ExclusiveReentrantLockManager(boolean trackLocks)
ExclusiveReentrantLockManager(boolean trackLocks, int collectionFrequency)

Method Summary

Modifier and Type	Method	Description
Lock	getExclusiveLock()
private Lock	getExclusiveLockInner()
boolean	isActiveLock()
Lock	tryExclusiveLock()
private Lock	tryExclusiveLockInner()

Methods inherited from class Object

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

Field Details

logger

private static final org.slf4j.Logger logger

activeLocks

final AtomicLong activeLocks

owner

final AtomicReference<Thread> owner

waitToCollect

private final int waitToCollect

lockMonitoring

LockMonitoring<ExclusiveReentrantLockManager.ExclusiveReentrantLock> lockMonitoring

Constructor Details

ExclusiveReentrantLockManager

public ExclusiveReentrantLockManager()

ExclusiveReentrantLockManager

public ExclusiveReentrantLockManager(boolean trackLocks)

ExclusiveReentrantLockManager

public ExclusiveReentrantLockManager(boolean trackLocks,
 int collectionFrequency)

Method Details

tryExclusiveLockInner

private Lock tryExclusiveLockInner()

getExclusiveLockInner

private Lock getExclusiveLockInner()
                            throws InterruptedException

Throws:

InterruptedException

tryExclusiveLock

public Lock tryExclusiveLock()

getExclusiveLock

public Lock getExclusiveLock()
                      throws InterruptedException

Throws:

InterruptedException

isActiveLock

public boolean isActiveLock()