Package org.burningwave.core.concurrent

Class QueuedTasksExecutor

java.lang.Object

org.burningwave.core.concurrent.QueuedTasksExecutor

All Implemented Interfaces:

AutoCloseable, Closeable, Identifiable, ManagedLogger

public class QueuedTasksExecutor
extends Object
implements Closeable, ManagedLogger

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueuedTasksExecutor.Group
static class	QueuedTasksExecutor.ProducerTask<T>
static class	QueuedTasksExecutor.Task
static class	QueuedTasksExecutor.TaskAbst<E,T extends QueuedTasksExecutor.TaskAbst<E,T>>

Nested classes/interfaces inherited from interface org.burningwave.core.ManagedLogger

ManagedLogger.Repository

Method Summary

Modifier and Type	Method	Description
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> boolean	abort(T task)
QueuedTasksExecutor	changePriority(int priority)
void	close()
static QueuedTasksExecutor	create(String executorName, Thread.Supplier threadSupplier, int initialPriority)
static QueuedTasksExecutor	create(String executorName, Thread.Supplier threadSupplier, int initialPriority, boolean daemon, boolean undestroyable)
QueuedTasksExecutor.Task	createTask(ThrowingRunnable<? extends Throwable> executable)
<T> QueuedTasksExecutor.ProducerTask<T>	createTask(ThrowingSupplier<T,? extends Throwable> executable)
String	getInfoAsString()
void	logInfo()
void	logStatus()
QueuedTasksExecutor	resumeFromSuspension()
QueuedTasksExecutor	setTasksCreationTrackingFlag(boolean flag)
boolean	shutDown(boolean waitForTasksTermination)
QueuedTasksExecutor	suspend(boolean immediately, boolean ignoreDeadLocked)
QueuedTasksExecutor	suspend(boolean immediately, int priority, boolean ignoreDeadLocked)
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> QueuedTasksExecutor	waitFor(T task)
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> QueuedTasksExecutor	waitFor(T task, boolean ignoreDeadLocked)
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> QueuedTasksExecutor	waitFor(T task, int priority, boolean ignoreDeadLocked)
QueuedTasksExecutor	waitForTasksEnding()
QueuedTasksExecutor	waitForTasksEnding(int priority, boolean ignoreDeadLocked)
QueuedTasksExecutor	waitForTasksEnding(int priority, boolean waitForNewAddedTasks, boolean ignoreDeadLocked)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.burningwave.core.Closeable

closeResources, closeResources, createCloseResoucesTask, createCloseResoucesTask

Methods inherited from interface org.burningwave.core.Identifiable

getId, getOperationId

Methods inherited from interface org.burningwave.core.ManagedLogger

logDebug, logDebug, logError, logError, logError, logError, logError, logInfo, logInfo, logTrace, logTrace, logWarn, logWarn

Method Details

create

public static QueuedTasksExecutor create(String executorName,
Thread.Supplier threadSupplier,
int initialPriority)

create

public static QueuedTasksExecutor create(String executorName,
Thread.Supplier threadSupplier,
int initialPriority,
boolean daemon,
boolean undestroyable)

setTasksCreationTrackingFlag

public QueuedTasksExecutor setTasksCreationTrackingFlag(boolean flag)

createTask

public <T> QueuedTasksExecutor.ProducerTask<T> createTask(ThrowingSupplier<T,? extends Throwable> executable)

createTask

public QueuedTasksExecutor.Task createTask(ThrowingRunnable<? extends Throwable> executable)

waitFor

public <E,
T extends QueuedTasksExecutor.TaskAbst<E,
T>>
QueuedTasksExecutor waitFor(T task)

waitFor

public <E,
T extends QueuedTasksExecutor.TaskAbst<E,
T>>
QueuedTasksExecutor waitFor(T task,
boolean ignoreDeadLocked)

waitFor

public <E,
T extends QueuedTasksExecutor.TaskAbst<E,
T>>
QueuedTasksExecutor waitFor(T task,
int priority,
boolean ignoreDeadLocked)

waitForTasksEnding

public QueuedTasksExecutor waitForTasksEnding()

abort

public <E,
T extends QueuedTasksExecutor.TaskAbst<E,
T>>
boolean abort(T task)

waitForTasksEnding

public QueuedTasksExecutor waitForTasksEnding(int priority,
boolean waitForNewAddedTasks,
boolean ignoreDeadLocked)

waitForTasksEnding

public QueuedTasksExecutor waitForTasksEnding(int priority,
boolean ignoreDeadLocked)

changePriority

public QueuedTasksExecutor changePriority(int priority)

suspend

public QueuedTasksExecutor suspend(boolean immediately,
boolean ignoreDeadLocked)

suspend

public QueuedTasksExecutor suspend(boolean immediately,
int priority,
boolean ignoreDeadLocked)

resumeFromSuspension

public QueuedTasksExecutor resumeFromSuspension()

shutDown

public boolean shutDown(boolean waitForTasksTermination)

logStatus

public void logStatus()

getInfoAsString

public String getInfoAsString()

logInfo

public void logInfo()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable