|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use Task | |
|---|---|
| org.databene.benerator.engine | |
| org.databene.benerator.engine.statement | |
| org.databene.platform.contiperf | |
| org.databene.platform.file | |
| org.databene.task | Task definition and execution framework. |
| org.databene.task.runner | |
| org.databene.task.test | |
| Uses of Task in org.databene.benerator.engine |
|---|
| Subinterfaces of Task in org.databene.benerator.engine | |
|---|---|
interface |
GeneratorTask
Parent interface for Tasks that use a Generator to generate data
and a Consumer to consume it. |
| Uses of Task in org.databene.benerator.engine.statement |
|---|
| Classes in org.databene.benerator.engine.statement that implement Task | |
|---|---|
class |
GenerateAndConsumeTask
Task that creates one data set instance per run() invocation and sends it to the specified consumer. |
| Fields in org.databene.benerator.engine.statement declared as Task | |
|---|---|
protected Task |
RunTaskStatement.task
|
| Fields in org.databene.benerator.engine.statement with type parameters of type Task | |
|---|---|
protected org.databene.commons.Expression<? extends Task> |
RunTaskStatement.taskProvider
|
| Methods in org.databene.benerator.engine.statement that return Task | |
|---|---|
Task |
RunTaskStatement.getTask(BeneratorContext context)
|
| Constructor parameters in org.databene.benerator.engine.statement with type arguments of type Task | |
|---|---|
RunTaskStatement(org.databene.commons.Expression<? extends Task> taskProvider,
org.databene.commons.Expression<java.lang.Long> count,
org.databene.commons.Expression<java.lang.Long> pageSize,
org.databene.commons.Expression<PageListener> pageListener,
org.databene.commons.Expression<java.lang.Integer> threads,
org.databene.commons.Expression<java.lang.Boolean> stats,
org.databene.commons.Expression<org.databene.commons.ErrorHandler> errorHandler,
boolean infoLog)
|
|
| Uses of Task in org.databene.platform.contiperf |
|---|
| Classes in org.databene.platform.contiperf that implement Task | |
|---|---|
class |
PerfTrackingTaskProxy
Proxies a Task and tracks its execution times. |
| Constructors in org.databene.platform.contiperf with parameters of type Task | |
|---|---|
PerfTrackingTaskProxy(Task realTask)
|
|
PerfTrackingTaskProxy(Task realTask,
org.databene.contiperf.PerformanceTracker tracker)
|
|
TaskInvoker(Task target)
|
|
| Uses of Task in org.databene.platform.file |
|---|
| Classes in org.databene.platform.file that implement Task | |
|---|---|
class |
FileDeleter
Deletes one or more files. |
class |
FileJoiner
Joins several source files into a destination file. |
| Uses of Task in org.databene.task |
|---|
| Classes in org.databene.task with type parameters of type Task | |
|---|---|
class |
StateTrackingTaskProxy<E extends Task>
Task proxy that remembers the result of the last execution step and provides it as property available. |
class |
TaskProxy<E extends Task>
Wraps a Task and forwards invocations. |
class |
TimedTask<E extends Task>
Wraps a Task and logs its execution time. |
| Classes in org.databene.task that implement Task | |
|---|---|
class |
AbstractTask
Simple abstract implementation of the Task interface. |
class |
CompositeTask
Parent class for a Task that wrap several other Tasks. |
class |
RunnableTask
Wraps a Runnable in a Task. |
class |
SequentialTask
Task implementation that executes a series of other tasks consecutively. |
class |
StateTrackingTaskProxy<E extends Task>
Task proxy that remembers the result of the last execution step and provides it as property available. |
class |
SynchronizedTask
TaskProxy implementation that add thread-safety to an unsafe
Task by synchronizing the method execute(Context, ErrorHandler). |
class |
TaskProxy<E extends Task>
Wraps a Task and forwards invocations. |
class |
TimedTask<E extends Task>
Wraps a Task and logs its execution time. |
| Fields in org.databene.task declared as Task | |
|---|---|
protected E |
TaskProxy.realTask
|
| Fields in org.databene.task with type parameters of type Task | |
|---|---|
protected java.util.List<Task> |
CompositeTask.subTasks
|
| Methods in org.databene.task with type parameters of type Task | ||
|---|---|---|
static
|
TaskUtil.unwrap(Task task,
java.lang.Class<T> type)
|
|
| Methods in org.databene.task that return Task | |
|---|---|
Task[] |
CompositeTask.getSubTasks()
|
Task |
TaskUnavailableException.getTask()
|
| Methods in org.databene.task with parameters of type Task | ||
|---|---|---|
void |
CompositeTask.addSubTask(Task task)
|
|
protected TaskResult |
SequentialTask.runSubTask(Task subTask,
org.databene.commons.Context context,
org.databene.commons.ErrorHandler errorHandler)
|
|
static
|
TaskUtil.unwrap(Task task,
java.lang.Class<T> type)
|
|
| Constructors in org.databene.task with parameters of type Task | |
|---|---|
CompositeTask(Task... subTasks)
|
|
SequentialTask(Task... subTasks)
|
|
SynchronizedTask(Task realTask)
|
|
TaskUnavailableException(Task task,
long requiredCount,
long actualCount)
|
|
| Uses of Task in org.databene.task.runner |
|---|
| Fields in org.databene.task.runner declared as Task | |
|---|---|
protected Task |
MultiThreadedTaskRunner.target
|
| Fields in org.databene.task.runner with type parameters of type Task | |
|---|---|
protected StateTrackingTaskProxy<? extends Task> |
PagedTaskRunner.target
|
| Methods in org.databene.task.runner with parameters of type Task | |
|---|---|
static org.databene.contiperf.PerformanceTracker |
PagedTaskRunner.execute(Task task,
org.databene.commons.Context context,
java.lang.Long requestedInvocations,
java.lang.Long minInvocations,
java.util.List<PageListener> pageListeners,
long pageSize,
int threadCount,
boolean stats,
java.util.concurrent.ExecutorService executorService,
org.databene.commons.ErrorHandler errorHandler,
boolean infoLog)
|
static long |
SingleThreadedTaskRunner.runWithoutPage(Task target,
java.lang.Long invocationCount,
org.databene.commons.Context context,
org.databene.commons.ErrorHandler errorHandler)
|
| Constructors in org.databene.task.runner with parameters of type Task | |
|---|---|
MultiThreadedTaskRunner(Task target,
int threadCount,
org.databene.commons.Context context,
java.util.concurrent.ExecutorService executorService,
org.databene.commons.ErrorHandler errorHandler,
org.databene.contiperf.PerformanceTracker tracker)
|
|
PagedTaskRunner(Task target,
java.util.List<PageListener> listeners,
long pageSize,
int threads,
boolean stats,
java.util.concurrent.ExecutorService executor)
|
|
PagedTaskRunner(Task target,
java.util.List<PageListener> pageListeners,
long pageSize,
int threads,
boolean stats,
org.databene.commons.Expression<java.util.concurrent.ExecutorService> executor,
org.databene.commons.Context context,
org.databene.commons.ErrorHandler errorHandler)
|
|
SingleThreadedTaskRunner(Task target,
boolean finishPages,
org.databene.commons.Context context,
org.databene.commons.ErrorHandler errorHandler)
|
|
| Uses of Task in org.databene.task.test |
|---|
| Methods in org.databene.task.test with parameters of type Task | |
|---|---|
protected static void |
AbstractTaskTest.executeStepAndAssertAvailability(Task task,
org.databene.commons.Context context)
|
protected static void |
AbstractTaskTest.executeStepAndAssertUnavailability(Task task,
org.databene.commons.Context context)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||