Class LockTracking<T extends Lock>

java.lang.Object

org.eclipse.rdf4j.common.concurrent.locks.diagnostics.LockTracking<T>

All Implemented Interfaces:

LockMonitoring<T>

@InternalUseOnly
public class LockTracking<T extends Lock>
extends Object
implements LockMonitoring<T>

Full tracking of locks with simple deadlock detection and logging as well as automatic release of abandoned locks (same as LockCleaner).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LockTracking.SimpleLock<T extends Lock>

Nested classes/interfaces inherited from interface LockMonitoring

LockMonitoring.Wrapper<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final String	alias
private static final ConcurrentCleaner	cleaner
private int	currentWaitToCollect
private final Map<LockTracking.SimpleLock<T>, WeakReference<LockTracking.SimpleLock<T>>>	locks
static final int	LOGGED_STALLED_LOCKS_MINIMUM_WAIT_TO_COLLECT
private final org.slf4j.Logger	logger
private long	previousActiveLocksSignature
private long	previousCleanup
private static final AtomicLong	seq
private final boolean	stacktrace
private final ReentrantLock	staleLoggingLock
private final Lock.ExtendedSupplier<T>	supplier
private final int	waitToCollect

Fields inherited from interface LockMonitoring

INITIAL_WAIT_TO_COLLECT

Constructor Summary

Constructors

Constructor	Description
LockTracking(boolean stacktrace, String alias, org.slf4j.Logger logger, int waitToCollect, Lock.ExtendedSupplier<T> supplier)

Method Summary

Modifier and Type	Method	Description
private long	getActiveLocksSignature()
Lock	getLock()
Lock	getLock(String alias)
private LockTracking.SimpleLock<T>	getLockInner(T lock, String alias)
private void	logStalledLocks()
Lock	register(T lock)
boolean	requiresManualCleanup()
void	runCleanup()
Lock	tryLock()
void	unregister(Lock lock)
T	unsafeInnerLock(Lock lock)

Methods inherited from class Object

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

Field Details

LOGGED_STALLED_LOCKS_MINIMUM_WAIT_TO_COLLECT

public static final int LOGGED_STALLED_LOCKS_MINIMUM_WAIT_TO_COLLECT

See Also:

• Constant Field Values

logger

private final org.slf4j.Logger logger

cleaner

private static final ConcurrentCleaner cleaner

seq

private static final AtomicLong seq

staleLoggingLock

private final ReentrantLock staleLoggingLock

locks

private final Map<LockTracking.SimpleLock<T extends Lock>, WeakReference<LockTracking.SimpleLock<T extends Lock>>> locks

supplier

private final Lock.ExtendedSupplier<T extends Lock> supplier

stacktrace

private final boolean stacktrace

waitToCollect

private final int waitToCollect

alias

private final String alias

currentWaitToCollect

private int currentWaitToCollect

previousCleanup

private long previousCleanup

previousActiveLocksSignature

private long previousActiveLocksSignature

Constructor Details

LockTracking

public LockTracking(boolean stacktrace,
 String alias,
 org.slf4j.Logger logger,
 int waitToCollect,
 Lock.ExtendedSupplier<T> supplier)

Method Details

getActiveLocksSignature

private long getActiveLocksSignature()

logStalledLocks

private void logStalledLocks()

runCleanup

public void runCleanup()

Specified by:

runCleanup in interface LockMonitoring<T extends Lock>

getLock

public Lock getLock()
             throws InterruptedException

Specified by:

getLock in interface LockMonitoring<T extends Lock>

Throws:

InterruptedException

getLock

public Lock getLock(String alias)
             throws InterruptedException

Specified by:

getLock in interface LockMonitoring<T extends Lock>

Throws:

InterruptedException

unsafeInnerLock

public T unsafeInnerLock(Lock lock)

Specified by:

unsafeInnerLock in interface LockMonitoring<T extends Lock>

tryLock

public Lock tryLock()

Specified by:

tryLock in interface LockMonitoring<T extends Lock>

getLockInner

private LockTracking.SimpleLock<T> getLockInner(T lock,
 String alias)

requiresManualCleanup

public boolean requiresManualCleanup()

Specified by:

requiresManualCleanup in interface LockMonitoring<T extends Lock>

register

public Lock register(T lock)

Specified by:

register in interface LockMonitoring<T extends Lock>

unregister

public void unregister(Lock lock)

Specified by:

unregister in interface LockMonitoring<T extends Lock>