public static class TaskExecutorService.TaskWrapper extends Object implements FinishableStateUpdateHandler
Constructor and Description |
---|
TaskWrapper(TaskRunnerCallable taskRunnerCallable,
TaskExecutorService taskExecutorService) |
Modifier and Type | Method and Description |
---|---|
void |
finishableStateUpdated(boolean finishableState) |
String |
getRequestId() |
TaskRunnerCallable |
getTaskRunnerCallable() |
boolean |
isInPreemptionQueue() |
boolean |
isInWaitQueue() |
boolean |
maybeRegisterForFinishedStateNotifications(boolean currentFinishableState) |
void |
maybeUnregisterForFinishedStateNotifications() |
void |
setIsInPreemptableQueue(boolean value) |
void |
setIsInWaitQueue(boolean value) |
String |
toString() |
public TaskWrapper(TaskRunnerCallable taskRunnerCallable, TaskExecutorService taskExecutorService)
public boolean maybeRegisterForFinishedStateNotifications(boolean currentFinishableState)
currentFinishableState
- public void maybeUnregisterForFinishedStateNotifications()
public TaskRunnerCallable getTaskRunnerCallable()
public boolean isInWaitQueue()
public boolean isInPreemptionQueue()
public void setIsInWaitQueue(boolean value)
public void setIsInPreemptableQueue(boolean value)
public String getRequestId()
public void finishableStateUpdated(boolean finishableState)
finishableStateUpdated
in interface FinishableStateUpdateHandler
Copyright © 2016 The Apache Software Foundation. All rights reserved.