Package org.apache.sysds.runtime.util
Class DependencyTask<E>
- java.lang.Object
-
- org.apache.sysds.runtime.util.DependencyTask<E>
-
- All Implemented Interfaces:
Comparable<DependencyTask<?>>
,Callable<E>
- Direct Known Subclasses:
DependencyWrapperTask
public class DependencyTask<E> extends Object implements Comparable<DependencyTask<?>>, Callable<E>
-
-
Field Summary
Fields Modifier and Type Field Description List<DependencyTask<?>>
_dependencyTasks
static boolean
ENABLE_DEBUG_DATA
-
Constructor Summary
Constructors Constructor Description DependencyTask(Callable<E> task, List<DependencyTask<?>> dependantTasks)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addDependent(DependencyTask<?> dependencyTask)
void
addPool(ExecutorService pool)
void
assignFuture(CompletableFuture<Future<?>> f)
E
call()
int
compareTo(DependencyTask<?> task)
boolean
hasDependency(DependencyTask<?> dependencyTask)
boolean
isReady()
void
setPriority(int priority)
String
toString()
-
-
-
Field Detail
-
ENABLE_DEBUG_DATA
public static final boolean ENABLE_DEBUG_DATA
- See Also:
- Constant Field Values
-
_dependencyTasks
public List<DependencyTask<?>> _dependencyTasks
-
-
Constructor Detail
-
DependencyTask
public DependencyTask(Callable<E> task, List<DependencyTask<?>> dependantTasks)
-
-
Method Detail
-
addPool
public void addPool(ExecutorService pool)
-
assignFuture
public void assignFuture(CompletableFuture<Future<?>> f)
-
isReady
public boolean isReady()
-
setPriority
public void setPriority(int priority)
-
addDependent
public void addDependent(DependencyTask<?> dependencyTask)
-
hasDependency
public boolean hasDependency(DependencyTask<?> dependencyTask)
-
compareTo
public int compareTo(DependencyTask<?> task)
- Specified by:
compareTo
in interfaceComparable<E>
-
-