ClosableResource
, AsynchronousRunner
public class ThreadPerTaskAsynchronousRunner extends java.lang.Object implements AsynchronousRunner
Constructor | Description |
---|---|
ThreadPerTaskAsynchronousRunner(int max_task_threads) |
|
ThreadPerTaskAsynchronousRunner(int max_task_threads,
long interrupt_task_delay) |
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 |
getRunningCount() |
|
java.util.Collection |
getRunningTasks() |
|
int |
getWaitingCount() |
|
java.util.Collection |
getWaitingTasks() |
|
boolean |
isClosed() |
|
boolean |
isDoneAndGone() |
|
void |
postRunnable(java.lang.Runnable r) |
public ThreadPerTaskAsynchronousRunner(int max_task_threads)
public ThreadPerTaskAsynchronousRunner(int max_task_threads, long interrupt_task_delay)
public void postRunnable(java.lang.Runnable r)
postRunnable
in interface AsynchronousRunner
public void close()
AsynchronousRunner
close
in interface AsynchronousRunner
close
in interface ClosableResource
public void close(boolean skip_remaining_tasks)
AsynchronousRunner
close
in interface AsynchronousRunner
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.public int getRunningCount()
public java.util.Collection getRunningTasks()
public int getWaitingCount()
public java.util.Collection getWaitingTasks()
public boolean isClosed()
public boolean isDoneAndGone()