public class

TaskRunner

extends Object
implements Runnable
java.lang.Object
   ↳ org.apache.helix.task.TaskRunner

Class Overview

A wrapping Runnable used to manage the life-cycle of a user-defined Task implementation.

Summary

Public Constructors
TaskRunner(Task task, String taskName, String taskPartition, String instance, HelixManager manager, String sessionId)
Public Methods
void cancel()
Signals the task to cancel itself.
void run()
void timeout()
Signals the task to cancel itself.
TaskResult waitTillDone()
Waits uninterruptibly until the task has finished, either normally or due to an error/cancellation..
void waitTillStarted()
Waits uninterruptibly until the task has started.
[Expand]
Inherited Methods
From class java.lang.Object
From interface java.lang.Runnable

Public Constructors

public TaskRunner (Task task, String taskName, String taskPartition, String instance, HelixManager manager, String sessionId)

Public Methods

public void cancel ()

Signals the task to cancel itself.

public void run ()

public void timeout ()

Signals the task to cancel itself.

public TaskResult waitTillDone ()

Waits uninterruptibly until the task has finished, either normally or due to an error/cancellation..

public void waitTillStarted ()

Waits uninterruptibly until the task has started.