Package com.mchange.v2.async

Class ThreadPoolAsynchronousRunner

java.lang.Object

com.mchange.v2.async.ThreadPoolAsynchronousRunner

All Implemented Interfaces:

ClosableResource, AsynchronousRunner, ThreadPoolReportingAsynchronousRunner

public final class ThreadPoolAsynchronousRunner
extends Object
implements ThreadPoolReportingAsynchronousRunner

Constructor Summary

Constructors

Constructor	Description
ThreadPoolAsynchronousRunner(int num_threads, boolean daemon)
ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock)
ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, String threadLabel)
ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, int max_individual_task_time, int deadlock_detector_interval, int interrupt_delay_after_apparent_deadlock, Timer myTimer)
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(int num_threads, boolean daemon, Timer sharedTimer)
ThreadPoolAsynchronousRunner(int num_threads, boolean daemon, Timer sharedTimer, String threadLabel)

Method Summary

Modifier and Type	Method	Description
void	close()	Clean-up resources held by this asynchronous runner as soon as possible.
void	close(boolean skip_remaining_tasks)	Finish with this AsynchronousRunner, and clean-up any Threads or resources it may hold.
int	getActiveCount()
int	getIdleCount()
String	getMultiLineStatusString()
int	getPendingTaskCount()
String	getStackTraces()
String	getStatus()
int	getThreadCount()
void	postRunnable(Runnable r)

Methods inherited from class java.lang.Object

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

Constructor Details

ThreadPoolAsynchronousRunner

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

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

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

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

ThreadPoolAsynchronousRunner

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

ThreadPoolAsynchronousRunner

public ThreadPoolAsynchronousRunner(int num_threads,
 boolean daemon,
 Timer sharedTimer)

ThreadPoolAsynchronousRunner

public ThreadPoolAsynchronousRunner(int num_threads,
 boolean daemon)

Method Details

postRunnable

public void postRunnable(Runnable r)

Specified by:

postRunnable in interface AsynchronousRunner

getThreadCount

public int getThreadCount()

Specified by:

getThreadCount in interface ThreadPoolReportingAsynchronousRunner

close

public void close(boolean skip_remaining_tasks)

Description copied from interface: AsynchronousRunner

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

Specified by:

close in interface AsynchronousRunner

Parameters:

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

public void close()

Description copied from interface: AsynchronousRunner

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 ).

Specified by:

close in interface AsynchronousRunner

Specified by:

close in interface ClosableResource

getActiveCount

public int getActiveCount()

Specified by:

getActiveCount in interface ThreadPoolReportingAsynchronousRunner

getIdleCount

public int getIdleCount()

Specified by:

getIdleCount in interface ThreadPoolReportingAsynchronousRunner

getPendingTaskCount

public int getPendingTaskCount()

Specified by:

getPendingTaskCount in interface ThreadPoolReportingAsynchronousRunner

getStatus

public String getStatus()

Specified by:

getStatus in interface ThreadPoolReportingAsynchronousRunner

getStackTraces

public String getStackTraces()

Specified by:

getStackTraces in interface ThreadPoolReportingAsynchronousRunner

getMultiLineStatusString

public String getMultiLineStatusString()