com.mchange.v2.async
Class ThreadPoolAsynchronousRunner
java.lang.Object
com.mchange.v2.async.ThreadPoolAsynchronousRunner
- All Implemented Interfaces:
- ClosableResource, AsynchronousRunner
public final class ThreadPoolAsynchronousRunner
- extends Object
- implements AsynchronousRunner
Constructor Summary |
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,
Timer myTimer)
|
ThreadPoolAsynchronousRunner(int num_threads,
boolean daemon,
Timer sharedTimer)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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)
ThreadPoolAsynchronousRunner
public ThreadPoolAsynchronousRunner(int num_threads,
boolean daemon,
Timer sharedTimer)
ThreadPoolAsynchronousRunner
public ThreadPoolAsynchronousRunner(int num_threads,
boolean daemon)
postRunnable
public void postRunnable(Runnable r)
- Specified by:
postRunnable
in interface AsynchronousRunner
getThreadCount
public int getThreadCount()
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 ClosableResource
- Specified by:
close
in interface AsynchronousRunner
getActiveCount
public int getActiveCount()
getIdleCount
public int getIdleCount()
getPendingTaskCount
public int getPendingTaskCount()
getStatus
public String getStatus()
getStackTraces
public String getStackTraces()
getMultiLineStatusString
public String getMultiLineStatusString()