public static class TaskExecutorService.TaskWrapper extends Object implements FinishableStateUpdateHandler
Constructor and Description |
---|
TaskWrapper(TaskRunnerCallable taskRunnerCallable,
TaskExecutorService taskExecutorService) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
void |
finishableStateUpdated(boolean finishableState) |
String |
getRequestId() |
TaskRunnerCallable |
getTaskRunnerCallable() |
int |
hashCode() |
boolean |
isInPreemptionQueue() |
boolean |
isInWaitQueue() |
boolean |
maybeRegisterForFinishedStateNotifications(boolean currentFinishableState) |
void |
maybeUnregisterForFinishedStateNotifications() |
void |
setIsInPreemptableQueue(boolean value) |
void |
setIsInWaitQueue(boolean value) |
String |
toString() |
void |
updateCanFinishForPriority(boolean newFinishableState) |
public TaskWrapper(TaskRunnerCallable taskRunnerCallable, TaskExecutorService taskExecutorService)
public void updateCanFinishForPriority(boolean newFinishableState)
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 © 2021 The Apache Software Foundation. All rights reserved.