protected abstract class TaskBatcher.BatchedTask extends SourcePrioritizedRunnable
Modifier and Type | Field and Description |
---|---|
protected java.lang.Object |
batchingKey
the object that is used as batching key
|
protected java.util.concurrent.atomic.AtomicBoolean |
processed
whether the task has been processed already
|
protected java.lang.Object |
task
the task object that is wrapped
|
source
Modifier | Constructor and Description |
---|---|
protected |
BatchedTask(Priority priority,
java.lang.String source,
java.lang.Object batchingKey,
java.lang.Object task) |
Modifier and Type | Method and Description |
---|---|
abstract java.lang.String |
describeTasks(java.util.List<? extends TaskBatcher.BatchedTask> tasks) |
java.lang.Object |
getTask() |
void |
run() |
java.lang.String |
toString() |
source
compareTo, getAgeInMillis, getCreationDateInNanos, priority, wrap
protected final java.util.concurrent.atomic.AtomicBoolean processed
protected final java.lang.Object batchingKey
protected final java.lang.Object task
protected BatchedTask(Priority priority, java.lang.String source, java.lang.Object batchingKey, java.lang.Object task)
public void run()
public java.lang.String toString()
toString
in class SourcePrioritizedRunnable
public abstract java.lang.String describeTasks(java.util.List<? extends TaskBatcher.BatchedTask> tasks)
public java.lang.Object getTask()