Modifier and Type	Class and Description
pack-priv class	ThreadPoolAsynchronousRunner.DeadlockDetector
pack-priv class	ThreadPoolAsynchronousRunner.MaxIndividualTaskTimeEnforcer
pack-priv class	ThreadPoolAsynchronousRunner.PoolThread
pack-priv class	ThreadPoolAsynchronousRunner.ReplacedThreadInterruptor

Field Summary

Modifier and Type	Field and Description
pack-priv HashSet<E>	available
pack-priv boolean	daemon
pack-priv int	deadlock_detector_interval
pack-priv TimerTask	deadlockDetector
pack-priv static final int	DFLT_DEADLOCK_DETECTOR_INTERVAL
pack-priv static final int	DFLT_INTERRUPT_DELAY_AFTER_APPARENT_DEADLOCK
pack-priv static final int	DFLT_MAX_EMERGENCY_THREADS
pack-priv static final int	DFLT_MAX_INDIVIDUAL_TASK_TIME
pack-priv int	interrupt_delay_after_apparent_deadlock
pack-priv static final MLogger	logger
pack-priv HashSet<E>	managed
pack-priv int	max_individual_task_time
pack-priv Timer	myTimer
pack-priv int	num_threads
pack-priv LinkedList<E>	pendingTasks
pack-priv static final int	POLL_FOR_STOP_INTERVAL
pack-priv static final long	PURGE_EVERY
pack-priv TimerTask	replacedThreadInterruptor
pack-priv Random	rnd
pack-priv boolean	should_cancel_timer
pack-priv Map<K, V>	stoppedThreadsToStopDates
pack-priv String	threadLabel

Constructor Summary

Access	Constructor and Description
private	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer, boolean should_cancel_timer, String threadLabel)
private	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer, boolean should_cancel_timer)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer, String threadLabel)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, String threadLabel)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, Timer sharedTimer, String threadLabel)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, Timer sharedTimer)
public	ThreadPoolAsynchronousRunner(int num_threads, boolean daemon)

Method Summary

Modifier and Type	Method and Description
private void	appendStatusString(StringBuffer sb)
public void	close(boolean Should be regarded as a hint, not a guarantee. If true, pending, not-yet-performed tasks will be skipped, if possible. Currently executing tasks may or may not be interrupted. If false, all previously scheduled tasks will be completed prior to clean-up. The method returns immediately regardless. skip_remaining_tasks) Implements com.mchange.v2.async.AsynchronousRunner.close. Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold.
public void	close() Implements com.mchange.v2.async.AsynchronousRunner.close. Clean-up resources held by this asynchronous runner as soon as possible.
private void	ensureReplacedThreadsProcessing()
public synchronized int	getActiveCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getActiveCount.
public synchronized int	getIdleCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getIdleCount.
private String	getJvmStackTraces(int initial_indent)
public synchronized String	getMultiLineStatusString()
private String	getMultiLineStatusString(int initial_indent)
public synchronized int	getPendingTaskCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getPendingTaskCount.
public synchronized String	getStackTraces() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStackTraces.
private String	getStackTraces(int initial_indent)
public synchronized String	getStatus() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStatus.
public synchronized int	getThreadCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getThreadCount.
public synchronized void	postRunnable(Runnable r) Implements com.mchange.v2.async.AsynchronousRunner.postRunnable.
private void	printStackTraces(IndentedWriter iw, Object thread, Object[] stackTraces)
private void	processReplacedThreads()
private void	recreateThreadsAndTasks()
private void	runInEmergencyThread(final Runnable r)
private void	shuttingDown(ThreadPoolAsynchronousRunner.PoolThread pt)
private void	stopReplacedThreadsProcessing()

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

Field Detail

available	back to summary
pack-priv HashSet<E> available

daemon	back to summary
pack-priv boolean daemon

deadlock_detector_interval	back to summary
pack-priv int deadlock_detector_interval

deadlockDetector	back to summary
pack-priv TimerTask deadlockDetector

DFLT_DEADLOCK_DETECTOR_INTERVAL	back to summary
pack-priv static final int DFLT_DEADLOCK_DETECTOR_INTERVAL

DFLT_INTERRUPT_DELAY_AFTER_APPARENT_DEADLOCK	back to summary
pack-priv static final int DFLT_INTERRUPT_DELAY_AFTER_APPARENT_DEADLOCK

DFLT_MAX_EMERGENCY_THREADS	back to summary
pack-priv static final int DFLT_MAX_EMERGENCY_THREADS

DFLT_MAX_INDIVIDUAL_TASK_TIME	back to summary
pack-priv static final int DFLT_MAX_INDIVIDUAL_TASK_TIME

interrupt_delay_after_apparent_deadlock	back to summary
pack-priv int interrupt_delay_after_apparent_deadlock

logger	back to summary
pack-priv static final MLogger logger

managed	back to summary
pack-priv HashSet<E> managed

max_individual_task_time	back to summary
pack-priv int max_individual_task_time

myTimer	back to summary
pack-priv Timer myTimer

num_threads	back to summary
pack-priv int num_threads

pendingTasks	back to summary
pack-priv LinkedList<E> pendingTasks

POLL_FOR_STOP_INTERVAL	back to summary
pack-priv static final int POLL_FOR_STOP_INTERVAL

PURGE_EVERY	back to summary
pack-priv static final long PURGE_EVERY

replacedThreadInterruptor	back to summary
pack-priv TimerTask replacedThreadInterruptor

rnd	back to summary
pack-priv Random rnd

should_cancel_timer	back to summary
pack-priv boolean should_cancel_timer

stoppedThreadsToStopDates	back to summary
pack-priv Map<K, V> stoppedThreadsToStopDates

threadLabel	back to summary
pack-priv String threadLabel

Constructor Detail

ThreadPoolAsynchronousRunner	back to summary
private ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer, boolean should_cancel_timer, String threadLabel)

ThreadPoolAsynchronousRunner	back to summary
private ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer, boolean should_cancel_timer)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer, String threadLabel)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, String threadLabel)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, Timer sharedTimer, String threadLabel)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, Timer sharedTimer)

ThreadPoolAsynchronousRunner	back to summary
public ThreadPoolAsynchronousRunner(int num_threads, boolean daemon)

Method Detail

appendStatusString	back to summary
private void appendStatusString(StringBuffer sb)

close	back to summary
public void close(boolean skip_remaining_tasks) Implements com.mchange.v2.async.AsynchronousRunner.close. Doc from com.mchange.v2.async.AsynchronousRunner.close. Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold. Parameters skip_remaining_tasks:boolean Should be regarded as a hint, not a guarantee. If true, pending, not-yet-performed tasks will be skipped, if possible. Currently executing tasks may or may not be interrupted. If false, all previously scheduled tasks will be completed prior to clean-up. The method returns immediately regardless.

back to summary

public void close(boolean skip_remaining_tasks)

Implements com.mchange.v2.async.AsynchronousRunner.close.

Doc from com.mchange.v2.async.AsynchronousRunner.close.

Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold.

Parameters

skip_remaining_tasks:boolean: Should be regarded as a hint, not a guarantee. If true, pending, not-yet-performed tasks will be skipped, if possible. Currently executing tasks may or may not be interrupted. If false, all previously scheduled tasks will be completed prior to clean-up. The method returns immediately regardless.

close	back to summary
public void close() Implements com.mchange.v2.async.AsynchronousRunner.close. Doc from com.mchange.v2.async.AsynchronousRunner.close. Clean-up resources held by this asynchronous runner as soon as possible. Remaining tasks are skipped if possible, and any tasks executing when close() is called may or may not be interrupted. Equivalent to close( true ).

back to summary

public void close()

Implements com.mchange.v2.async.AsynchronousRunner.close.

Doc from com.mchange.v2.async.AsynchronousRunner.close.

Clean-up resources held by this asynchronous runner as soon as possible. Remaining tasks are skipped if possible, and any tasks executing when close() is called may or may not be interrupted. Equivalent to close( true ).

ensureReplacedThreadsProcessing	back to summary
private void ensureReplacedThreadsProcessing()

getActiveCount	back to summary
public synchronized int getActiveCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getActiveCount.

getIdleCount	back to summary
public synchronized int getIdleCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getIdleCount.

getJvmStackTraces	back to summary
private String getJvmStackTraces(int initial_indent)

getMultiLineStatusString	back to summary
public synchronized String getMultiLineStatusString()

getMultiLineStatusString	back to summary
private String getMultiLineStatusString(int initial_indent)

getPendingTaskCount	back to summary
public synchronized int getPendingTaskCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getPendingTaskCount.

getStackTraces	back to summary
public synchronized String getStackTraces() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStackTraces.

getStackTraces	back to summary
private String getStackTraces(int initial_indent)

getStatus	back to summary
public synchronized String getStatus() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getStatus.

getThreadCount	back to summary
public synchronized int getThreadCount() Implements com.mchange.v2.async.ThreadPoolReportingAsynchronousRunner.getThreadCount.

postRunnable	back to summary
public synchronized void postRunnable(Runnable r) Implements com.mchange.v2.async.AsynchronousRunner.postRunnable.

printStackTraces	back to summary
private void printStackTraces(IndentedWriter iw, Object thread, Object[] stackTraces) throws IOException

processReplacedThreads	back to summary
private void processReplacedThreads()

recreateThreadsAndTasks	back to summary
private void recreateThreadsAndTasks()

runInEmergencyThread	back to summary
private void runInEmergencyThread(final Runnable r)

shuttingDown	back to summary
private void shuttingDown(ThreadPoolAsynchronousRunner.PoolThread pt)

stopReplacedThreadsProcessing	back to summary
private void stopReplacedThreadsProcessing()

com.mchange.v2.async back to summary

pack-priv Class ThreadPoolAsynchronousRunner.DeadlockDetector

Class Inheritance

extends TimerTask

java.lang.Object
java.util.TimerTask
com.mchange.v2.async.ThreadPoolAsynchronousRunner.DeadlockDetector

Field Summary

Modifier and Type	Field and Description
pack-priv LinkedList<E>	current
pack-priv LinkedList<E>	last

Constructor Summary

Access	Constructor and Description
pack-priv	DeadlockDetector()

Method Summary

Modifier and Type	Method and Description
public void	run() Implements abstract java.util.TimerTask.run. Implements java.lang.Runnable.run. The action to be performed by this timer task.

Inherited from java.util.TimerTask:: cancel scheduledExecutionTime

Field Detail

current	back to summary
pack-priv LinkedList<E> current

last	back to summary
pack-priv LinkedList<E> last

Constructor Detail

DeadlockDetector	back to summary
pack-priv DeadlockDetector()

Method Detail

run

back to summary

public void run()

Implements abstract java.util.TimerTask.run.

Implements java.lang.Runnable.run.

Doc from java.util.TimerTask.run.

The action to be performed by this timer task.

com.mchange.v2.async back to summary

pack-priv Class ThreadPoolAsynchronousRunner.MaxIndividualTaskTimeEnforcer

Class Inheritance

extends TimerTask

java.lang.Object
java.util.TimerTask
com.mchange.v2.async.ThreadPoolAsynchronousRunner.MaxIndividualTaskTimeEnforcer

Field Summary

Modifier and Type	Field and Description
pack-priv String	fixedTaskStr
pack-priv Thread	interruptMe
pack-priv ThreadPoolAsynchronousRunner.PoolThread	pt
pack-priv String	threadStr

Constructor Summary

Access	Constructor and Description
pack-priv	MaxIndividualTaskTimeEnforcer(ThreadPoolAsynchronousRunner.PoolThread pt)
pack-priv	MaxIndividualTaskTimeEnforcer(Thread interruptMe, String threadStr, String fixedTaskStr)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements abstract java.util.TimerTask.run. Implements java.lang.Runnable.run. The action to be performed by this timer task.

Inherited from java.util.TimerTask:: cancel scheduledExecutionTime

Field Detail

fixedTaskStr	back to summary
pack-priv String fixedTaskStr

interruptMe	back to summary
pack-priv Thread interruptMe

pt	back to summary
pack-priv ThreadPoolAsynchronousRunner.PoolThread pt

threadStr	back to summary
pack-priv String threadStr

Constructor Detail

MaxIndividualTaskTimeEnforcer	back to summary
pack-priv MaxIndividualTaskTimeEnforcer(ThreadPoolAsynchronousRunner.PoolThread pt)

MaxIndividualTaskTimeEnforcer	back to summary
pack-priv MaxIndividualTaskTimeEnforcer(Thread interruptMe, String threadStr, String fixedTaskStr)

Method Detail

run

back to summary

public void run()

Implements abstract java.util.TimerTask.run.

Implements java.lang.Runnable.run.

Doc from java.util.TimerTask.run.

The action to be performed by this timer task.

com.mchange.v2.async back to summary

pack-priv Class ThreadPoolAsynchronousRunner.PoolThread

Class Inheritance

extends Thread

java.lang.Object
java.lang.Thread
com.mchange.v2.async.ThreadPoolAsynchronousRunner.PoolThread

Field Summary

Modifier and Type	Field and Description
pack-priv Runnable	currentTask
pack-priv int	index
pack-priv TimerTask	maxIndividualTaskTimeEnforcer
pack-priv boolean	should_stop

Inherited from java.lang.Thread:: MAX_PRIORITY MIN_PRIORITY NORM_PRIORITY

Constructor Summary

Access	Constructor and Description
pack-priv	PoolThread(int index, boolean daemon)

Method Summary

Modifier and Type	Method and Description
private void	cancelMaxIndividualTaskTimeEnforcer()
pack-priv void	gentleStop()
pack-priv Runnable	getCurrentTask()
public int	getIndex()
private void	purgeTimer()
public void	run() Overrides java.lang.Thread.run. Implements java.lang.Runnable.run. This method is run by the thread when it executes.
private void	setMaxIndividualTaskTimeEnforcer()

Field Detail

currentTask	back to summary
pack-priv Runnable currentTask

index	back to summary
pack-priv int index

maxIndividualTaskTimeEnforcer	back to summary
pack-priv TimerTask maxIndividualTaskTimeEnforcer

should_stop	back to summary
pack-priv boolean should_stop

Constructor Detail

PoolThread	back to summary
pack-priv PoolThread(int index, boolean daemon)

Method Detail

cancelMaxIndividualTaskTimeEnforcer	back to summary
private void cancelMaxIndividualTaskTimeEnforcer()

gentleStop	back to summary
pack-priv void gentleStop()

getCurrentTask	back to summary
pack-priv Runnable getCurrentTask()

getIndex	back to summary
public int getIndex()

purgeTimer	back to summary
private void purgeTimer()

run back to summary

public void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

Doc from java.lang.Thread.run.

This method is run by the thread when it executes. Subclasses of Thread may override this method.

This method is not intended to be invoked directly. If this thread is a platform thread created with a Runnable task then invoking this method will invoke the task's run method. If this thread is a virtual thread then invoking this method directly does nothing.

setMaxIndividualTaskTimeEnforcer	back to summary
private void setMaxIndividualTaskTimeEnforcer()

com.mchange.v2.async back to summary

pack-priv Class ThreadPoolAsynchronousRunner.ReplacedThreadInterruptor

Class Inheritance

extends TimerTask

java.lang.Object
java.util.TimerTask
com.mchange.v2.async.ThreadPoolAsynchronousRunner.ReplacedThreadInterruptor

Constructor Summary

Access	Constructor and Description
pack-priv	ReplacedThreadInterruptor()

Method Summary

Modifier and Type	Method and Description
public void	run() Implements abstract java.util.TimerTask.run. Implements java.lang.Runnable.run. The action to be performed by this timer task.

Inherited from java.util.TimerTask:: cancel scheduledExecutionTime

Constructor Detail

ReplacedThreadInterruptor	back to summary
pack-priv ReplacedThreadInterruptor()

Method Detail

run

back to summary

public void run()

Implements abstract java.util.TimerTask.run.

Implements java.lang.Runnable.run.

Doc from java.util.TimerTask.run.

The action to be performed by this timer task.

public final Class ThreadPoolAsynchronousRunner

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class ThreadPoolAsynchronousRunner.DeadlockDetector

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class ThreadPoolAsynchronousRunner.MaxIndividualTaskTimeEnforcer

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class ThreadPoolAsynchronousRunner.PoolThread

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class ThreadPoolAsynchronousRunner.ReplacedThreadInterruptor

Constructor Summary

Method Summary

Constructor Detail

Method Detail