Top Description Fields Constructors Methods

org.h2.util

public Class AbbaLockingDetector

Class Inheritance

extends Object
implements Runnable

java.lang.Object
org.h2.util.AbbaLockingDetector

All Implemented Interfaces

java.lang.Runnable

Imports

java.lang.management.ManagementFactory, .MonitorInfo, .ThreadInfo, .ThreadMXBean, java.util.ArrayList, .Arrays, .HashSet, .List, .Map, .Set, .WeakHashMap

Utility to detect AB-BA deadlocks.

Field Summary

Modifier and Type	Field and Description
private final Set<String>	knownDeadlocks
private final Map<String, Map<String, String>>	lockOrdering Map of (object A) -> ( map of (object locked before object A) -> (stack trace where locked) )
private volatile boolean	stop
private Thread	thread
private final ThreadMXBean	threadMXBean
private final int	tickIntervalMs

Constructor Summary

Access	Constructor and Description
public	AbbaLockingDetector()

Method Summary

Modifier and Type	Method and Description
private static void	dumpStackTraceElement(ThreadInfo info, StringBuilder sb, int i, StackTraceElement e)
private static void	generateOrdering(List<String> lockOrder, ThreadInfo info) We cannot simply call getLockedMonitors because it is not guaranteed to return the locks in the correct order.
private static String	getObjectName(MonitorInfo info)
private static String	getStackTraceForThread(ThreadInfo info) Dump data in the same format as `ThreadInfo#toString()`, but with some modifications (no stack frame limit, and removal of uninteresting stack frames)
private synchronized void	markHigher(List<String> lockOrder, ThreadInfo threadInfo)
private void	processThreadList(ThreadInfo[] threadInfoList)
public synchronized void	reset() Reset the state.
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public AbbaLockingDetector	Returns: this startCollecting() Start collecting locking data.
public AbbaLockingDetector	Returns: this stopCollecting() Stop collecting.
private void	tick()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

knownDeadlocks	back to summary
private final Set<String> knownDeadlocks

lockOrdering	back to summary
private final Map<String, Map<String, String>> lockOrdering Map of (object A) -> ( map of (object locked before object A) -> (stack trace where locked) )

stop	back to summary
private volatile boolean stop

thread	back to summary
private Thread thread

threadMXBean	back to summary
private final ThreadMXBean threadMXBean

tickIntervalMs	back to summary
private final int tickIntervalMs

Constructor Detail

AbbaLockingDetector	back to summary
public AbbaLockingDetector()

Method Detail

dumpStackTraceElement	back to summary
private static void dumpStackTraceElement(ThreadInfo info, StringBuilder sb, int i, StackTraceElement e)

generateOrdering	back to summary
private static void generateOrdering(List<String> lockOrder, ThreadInfo info) We cannot simply call getLockedMonitors because it is not guaranteed to return the locks in the correct order.

getObjectName	back to summary
private static String getObjectName(MonitorInfo info)

getStackTraceForThread	back to summary
private static String getStackTraceForThread(ThreadInfo info) Dump data in the same format as `ThreadInfo#toString()`, but with some modifications (no stack frame limit, and removal of uninteresting stack frames)

markHigher	back to summary
private synchronized void markHigher(List<String> lockOrder, ThreadInfo threadInfo)

processThreadList	back to summary
private void processThreadList(ThreadInfo[] threadInfoList)

reset	back to summary
public synchronized void reset() Reset the state.

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

startCollecting

back to summary

public AbbaLockingDetector startCollecting()

Start collecting locking data.

Returns:AbbaLockingDetector: this

stopCollecting

back to summary

public AbbaLockingDetector stopCollecting()

Stop collecting.

Returns:AbbaLockingDetector: this

tick	back to summary
private void tick()