com.mchange.v2.async
Class ThreadPoolAsynchronousRunner

java.lang.Object
  extended by 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)
           
 
Method Summary
 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 Detail

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)
Method Detail

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