Class LockCleaner<T extends Lock>

java.lang.Object

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

All Implemented Interfaces:

LockMonitoring<T>

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

Automatically log and release locks that are no longer referenced and will be garbage collected.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LockCleaner.CleanableLock<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 final org.slf4j.Logger	logger
private final boolean	stacktrace
private final Lock.ExtendedSupplier<T>	supplier

Fields inherited from interface LockMonitoring

INITIAL_WAIT_TO_COLLECT

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Lock	getLock()
private LockCleaner.CleanableLock<T>	getLockInner(T lock)
Lock	register(T lock)
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

Methods inherited from interface LockMonitoring

getLock, requiresManualCleanup, runCleanup

Field Details

cleaner

private static final ConcurrentCleaner cleaner

logger

private final org.slf4j.Logger logger

supplier

private final Lock.ExtendedSupplier<T extends Lock> supplier

alias

private final String alias

stacktrace

private final boolean stacktrace

Constructor Details

LockCleaner

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

Method Details

getLock

public Lock getLock()
             throws InterruptedException

Specified by:

getLock in interface LockMonitoring<T extends Lock>

Throws:

InterruptedException

tryLock

public Lock tryLock()

Specified by:

tryLock in interface LockMonitoring<T extends Lock>

unsafeInnerLock

public T unsafeInnerLock(Lock lock)

Specified by:

unsafeInnerLock 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>

getLockInner

private LockCleaner.CleanableLock<T> getLockInner(T lock)