Uses of Interface
org.jppf.node.protocol.Task
Packages that use Task
Package
Description
Interfaces for the new load-balancing execution on the client and server side.
Interfaces for the new load-balancing execution on the client and server side.
Support for transport-agnostic communication with remote services and disk overflow.
Support for job selectors and
job management in the server.
Support for node life cycle events
and task notifications.
Support for graphs of tasks within jobs and graphs of jobs.
-
Uses of Task in org.jppf.client.taskwrapper
Classes in org.jppf.client.taskwrapper that implement TaskModifier and TypeClassDescriptionclassJPPF task wrapper for an object whose class is annotated withJPPFRunnable.Methods in org.jppf.client.taskwrapper that return Task -
Uses of Task in org.jppf.execute
Fields in org.jppf.execute with type parameters of type TaskMethods in org.jppf.execute that return TaskModifier and TypeMethodDescriptionTask<?>NodeTaskWrapper.getTask()Get the task this wrapper executes within a try/catch block.Method parameters in org.jppf.execute with type arguments of type TaskModifier and TypeMethodDescriptionvoidAbstractExecutionManager.execute(TaskBundle bundle, List<Task<?>> taskList) voidExecutionManager.execute(TaskBundle bundle, List<Task<?>> taskList) Execute the specified tasks of the specified tasks bundle.protected abstract voidAbstractExecutionManager.setup(TaskBundle bundle, List<Task<?>> taskList) Prepare this execution manager for executing the tasks of a bundle.Constructors in org.jppf.execute with parameters of type TaskModifierConstructorDescriptionNodeTaskWrapper(JobProcessingEntry jobEntry, Task<?> task, ClassLoader taskClassLoader, JPPFScheduleHandler timeoutHandler) Initialize this task wrapper with a specified JPPF task.NodeTaskWrapper(Task<?> task, ClassLoader taskClassLoader, JPPFScheduleHandler timeoutHandler) Initialize this task wrapper with a specified JPPF task. -
Uses of Task in org.jppf.execute.async
Fields in org.jppf.execute.async with type parameters of type TaskMethod parameters in org.jppf.execute.async with type arguments of type TaskModifier and TypeMethodDescriptionvoidExecutionManagerListener.bundleExecuted(TaskBundle bundle, List<Task<?>> tasks, Throwable t) Called when the execution of a task bundle has finished.protected voidAbstractAsyncExecutionManager.fireJobFinished(TaskBundle bundle, List<Task<?>> tasks, Throwable t) Called when the execution of a task bundle has finished. -
Uses of Task in org.jppf.ga
Classes in org.jppf.ga that implement Task -
Uses of Task in org.jppf.job
Methods in org.jppf.job that return TaskModifier and TypeMethodDescriptionTask<?>ServerTaskInformation.getResultAsTask()Deserialize the result into a Task object. -
Uses of Task in org.jppf.node.event
Methods in org.jppf.node.event that return TaskModifier and TypeMethodDescriptionTask<?>TaskExecutionEvent.getTask()Get the JPPF task from which the event originates.Constructors in org.jppf.node.event with parameters of type TaskModifierConstructorDescriptionTaskExecutionEvent(Task<?> task, String jobId, String jobName, long cpuTime, long elapsedTime, boolean error) Initialize this event object with the specified task.TaskExecutionEvent(Task<?> task, String jobId, String jobName, Object userObject, boolean sendViaJmx) Initialize this event object with the specified task. -
Uses of Task in org.jppf.node.protocol
Classes in org.jppf.node.protocol that implement TaskModifier and TypeClassDescriptionclassAbstractTask<T>Abstract superclass for all tasks submitted to the execution server.classInstances of this class encapsulate the execution of an external process, program or shell script.
This task starts and external process using command line arguments, environment variables, and a list of input and/or output files to use or generated by the external process.
This task also captures the standard and error output (i.e. equivalent to System.out and System.err) of the external process.classInstances of this class are used to signal that a task could not be sent back by the node to the server.classclassThis class is kept for compatibility with existing user installations which make use of it, as we understand there are quite a few that still do.classScriptedTask<T>A task implementation which executes a script in a specified JSR 223 (javax.scriptAPIs) script language.Methods in org.jppf.node.protocol that return TaskModifier and TypeMethodDescriptionAbstractTask.fireNotification(Object userObject, boolean sendViaJmx) Task.fireNotification(Object userObject, boolean sendViaJmx) Causes the task to send a notification to all listeners.AbstractTask.setDataProvider(DataProvider dataProvider) Set the provider of shared data for this task.Task.setDataProvider(DataProvider dataProvider) Set the provider of shared data for this task.Set the user-assigned id for this task.AbstractTask.setInNode(boolean inNode) Determine whether this task is executing within a node, or locally on the client side.Task.setInNode(boolean inNode) Determine whether this task is executing within a node, or locally on the client side.AbstractTask.setJob(JPPFDistributedJob job) set the job this task is a part of.Task.setJob(JPPFDistributedJob job) set the job this task is a part of.AbstractTask.setMaxResubmits(int maxResubmits) Task.setMaxResubmits(int maxResubmits) Set the maximum number of times a task can resubmit itself.Set the node in which this task is executing, if any.Set the node in which this task is executing, if any.AbstractTask.setPosition(int position) Set the position of this element in its container.AbstractTask.setResubmit(boolean resubmit) Specify whether this task should be resubmitted by the server.Task.setResubmit(boolean resubmit) Specify whether this task should be resubmitted by the server.Set the result of the task execution.AbstractTask.setThrowable(Throwable throwable) Task.setThrowable(Throwable throwable) Sets the Throwable that was raised by this task's execution in therun()method.AbstractTask.setTimeoutSchedule(JPPFSchedule timeoutSchedule) Task.setTimeoutSchedule(JPPFSchedule timeoutSchedule) Get the task timeout schedule configuration.Methods in org.jppf.node.protocol that return types with arguments of type TaskMethods in org.jppf.node.protocol with parameters of type TaskModifier and TypeMethodDescriptionvoidTaskExecutionDispatcher.fireTaskEnded(Task<?> task, String jobId, String jobName, long cpuTime, long elapsedTime, boolean error) Fire an event to notify that a task has ended its execution.voidTaskExecutionDispatcher.fireTaskNotification(Task<?> task, Object userObject, boolean sendViaJmx) Fire an event from a task.Constructor parameters in org.jppf.node.protocol with type arguments of type Task -
Uses of Task in org.jppf.node.protocol.graph
Subinterfaces of Task in org.jppf.node.protocol.graphModifier and TypeInterfaceDescriptioninterfaceTaskNode<T>Interface for tasks that are part of a dependency graph of tasks within a job.
Dependencies can be added using thedependsOn(Collection<TaskNode>)anddependsOn(TaskNode...)methods.Classes in org.jppf.node.protocol.graph that implement TaskModifier and TypeClassDescriptionclassInstances of this class represent tasks that are part of a dependency graph of tasks within a job.
Dependencies can be added using thedependsOn(Collection<TaskNode>)anddependsOn(TaskNode...)methods.Method parameters in org.jppf.node.protocol.graph with type arguments of type TaskModifier and TypeMethodDescriptionstatic TaskGraphTaskGraphHelper.graphOf(Collection<Task<?>> tasks) Build a task graph from the specified collection of tasks.