Skip to content

Commit

Permalink
Add applyAsync()
Browse files Browse the repository at this point in the history
  • Loading branch information
jianghaolu committed Jun 15, 2016
1 parent bc57070 commit 5aac1fa
Showing 1 changed file with 11 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -27,9 +27,20 @@ public interface TaskItem<U> {
* once executed the result will be available through result getter
*
* @param taskGroup the task group dispatching tasks
* @param node the node the task item is associated with
* @throws Exception exception
*/
void execute(TaskGroup<U, TaskItem<U>> taskGroup, DAGNode<TaskItem<U>> node) throws Exception;

/**
* Executes the task asynchronously.
* <p>
* once executed the result will be available through result getter
* @param taskGroup the task group dispatching tasks
* @param node the node the task item is associated with
* @param callback callback to call on success or failure
* @return the handle of the REST call
*/
ServiceCall executeAsync(TaskGroup<U, TaskItem<U>> taskGroup, DAGNode<TaskItem<U>> node, ServiceCallback<Void> callback);
}

0 comments on commit 5aac1fa

Please sign in to comment.