Class QueuedTasksExecutor.TaskAbst<E,​T extends QueuedTasksExecutor.TaskAbst<E,​T>>

java.lang.Object
org.burningwave.core.concurrent.QueuedTasksExecutor.TaskAbst<E,​T>
All Implemented Interfaces:
ManagedLogger
Direct Known Subclasses:
QueuedTasksExecutor.ProducerTask, QueuedTasksExecutor.Task
Enclosing class:
QueuedTasksExecutor

public abstract static class QueuedTasksExecutor.TaskAbst<E,​T extends QueuedTasksExecutor.TaskAbst<E,​T>>
extends Object
implements ManagedLogger
  • Constructor Details

    • TaskAbst

      public TaskAbst​(E executable, boolean creationTracking)
  • Method Details

    • getCreatorInfos

      public List<StackTraceElement> getCreatorInfos()
    • getStartTime

      public Long getStartTime()
    • setName

      public T setName​(String name)
    • setExceptionHandler

      public T setExceptionHandler​(ThrowingBiConsumer<T,​Throwable,​Throwable> exceptionHandler)
    • isStarted

      public boolean isStarted()
    • hasFinished

      public boolean hasFinished()
    • runOnlyOnce

      public T runOnlyOnce​(String id, Supplier<Boolean> hasBeenExecutedChecker)
    • isAborted

      public boolean isAborted()
    • isSubmitted

      public boolean isSubmitted()
    • isProbablyDeadLocked

      public boolean isProbablyDeadLocked()
    • waitForStarting

      public T waitForStarting()
    • waitForStarting0

      public boolean waitForStarting0​(boolean ignoreDeadLocked)
    • waitForFinish

      public T waitForFinish()
    • waitForFinish

      public T waitForFinish​(boolean ignoreDeadLocked)
    • changePriority

      public T changePriority​(int priority)
    • setPriorityToCurrentThreadPriority

      public T setPriorityToCurrentThreadPriority()
    • getPriority

      public int getPriority()
    • getException

      public Throwable getException()
    • submit

      public final T submit()
    • abortOrWaitForFinish

      public T abortOrWaitForFinish()
    • abortOrWaitForFinish

      public T abortOrWaitForFinish​(boolean ignoreDeadLocked)
    • abort

      public T abort()