public final class Dependency
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
private class |
Dependency.Runner |
private static class |
Dependency.State |
| Modifier and Type | Field and Description |
|---|---|
private static java.lang.ThreadLocal<Dependency> |
CTH |
private static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<Dependency> |
depUpdater |
private java.util.concurrent.Executor |
executor |
private java.lang.Object |
lock |
private static org.jboss.logging.Logger |
log |
private int |
remainingDependencies
Number of dependencies left before this task can start.
|
private Dependency.Runner |
runner |
private Dependency.State |
state |
| Constructor and Description |
|---|
Dependency(java.util.concurrent.Executor executor,
java.lang.Runnable runnable,
int initialDepCount) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
addDependent(Dependency task) |
static Dependency |
currentTask()
Get the dependency task which this thread is currently running.
|
private void |
dependencyFailed() |
(package private) void |
dependencyFinished() |
private static final org.jboss.logging.Logger log
private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<Dependency> depUpdater
private volatile int remainingDependencies
private final java.util.concurrent.Executor executor
private final java.lang.Object lock
private Dependency.Runner runner
private Dependency.State state
private static final java.lang.ThreadLocal<Dependency> CTH
Dependency(java.util.concurrent.Executor executor,
java.lang.Runnable runnable,
int initialDepCount)
void addDependent(Dependency task)
void dependencyFinished()
private void dependencyFailed()
public static Dependency currentTask()
null if the current thread is not running a dependency task