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 java.lang.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 classLockTracking.SimpleLock<T extends Lock>-
Nested classes/interfaces inherited from interface org.eclipse.rdf4j.common.concurrent.locks.diagnostics.LockMonitoring
LockMonitoring.Wrapper<T extends Lock>
-
-
Field Summary
Fields Modifier and Type Field Description private java.lang.Stringaliasprivate static ConcurrentCleanercleanerprivate intcurrentWaitToCollectprivate java.util.Map<LockTracking.SimpleLock<T>,java.lang.ref.WeakReference<LockTracking.SimpleLock<T>>>locksstatic intLOGGED_STALLED_LOCKS_MINIMUM_WAIT_TO_COLLECTprivate org.slf4j.Loggerloggerprivate longpreviousActiveLocksSignatureprivate longpreviousCleanupprivate static java.util.concurrent.atomic.AtomicLongseqprivate booleanstacktraceprivate java.util.concurrent.locks.ReentrantLockstaleLoggingLockprivate Lock.ExtendedSupplier<T>supplierprivate intwaitToCollect-
Fields inherited from interface org.eclipse.rdf4j.common.concurrent.locks.diagnostics.LockMonitoring
INITIAL_WAIT_TO_COLLECT
-
-
Constructor Summary
Constructors Constructor Description LockTracking(boolean stacktrace, java.lang.String alias, org.slf4j.Logger logger, int waitToCollect, Lock.ExtendedSupplier<T> supplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description private longgetActiveLocksSignature()LockgetLock()LockgetLock(java.lang.String alias)private LockTracking.SimpleLock<T>getLockInner(T lock, java.lang.String alias)private voidlogStalledLocks()Lockregister(T lock)booleanrequiresManualCleanup()voidrunCleanup()LocktryLock()voidunregister(Lock lock)TunsafeInnerLock(Lock lock)
-
-
-
Field Detail
-
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 java.util.concurrent.atomic.AtomicLong seq
-
staleLoggingLock
private final java.util.concurrent.locks.ReentrantLock staleLoggingLock
-
locks
private final java.util.Map<LockTracking.SimpleLock<T extends Lock>,java.lang.ref.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 java.lang.String alias
-
currentWaitToCollect
private int currentWaitToCollect
-
previousCleanup
private long previousCleanup
-
previousActiveLocksSignature
private long previousActiveLocksSignature
-
-
Constructor Detail
-
LockTracking
public LockTracking(boolean stacktrace, java.lang.String alias, org.slf4j.Logger logger, int waitToCollect, Lock.ExtendedSupplier<T> supplier)
-
-
Method Detail
-
getActiveLocksSignature
private long getActiveLocksSignature()
-
logStalledLocks
private void logStalledLocks()
-
runCleanup
public void runCleanup()
- Specified by:
runCleanupin interfaceLockMonitoring<T extends Lock>
-
getLock
public Lock getLock() throws java.lang.InterruptedException
- Specified by:
getLockin interfaceLockMonitoring<T extends Lock>- Throws:
java.lang.InterruptedException
-
getLock
public Lock getLock(java.lang.String alias) throws java.lang.InterruptedException
- Specified by:
getLockin interfaceLockMonitoring<T extends Lock>- Throws:
java.lang.InterruptedException
-
unsafeInnerLock
public T unsafeInnerLock(Lock lock)
- Specified by:
unsafeInnerLockin interfaceLockMonitoring<T extends Lock>
-
tryLock
public Lock tryLock()
- Specified by:
tryLockin interfaceLockMonitoring<T extends Lock>
-
getLockInner
private LockTracking.SimpleLock<T> getLockInner(T lock, java.lang.String alias)
-
requiresManualCleanup
public boolean requiresManualCleanup()
- Specified by:
requiresManualCleanupin interfaceLockMonitoring<T extends Lock>
-
register
public Lock register(T lock)
- Specified by:
registerin interfaceLockMonitoring<T extends Lock>
-
unregister
public void unregister(Lock lock)
- Specified by:
unregisterin interfaceLockMonitoring<T extends Lock>
-
-