Package org.burningwave.core.concurrent

Class QueuedTasksExecutor.Group

java.lang.Object

org.burningwave.core.concurrent.QueuedTasksExecutor.Group

Enclosing class:

QueuedTasksExecutor

public static class QueuedTasksExecutor.Group
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	QueuedTasksExecutor.Group.TasksMonitorer

Method Summary

Modifier and Type	Method	Description
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> boolean	abort(T task)
static QueuedTasksExecutor.Group	create(String name, Thread.Supplier threadSupplier, boolean isDaemon, long allTasksMonitoringInterval, long minimumElapsedTimeToConsiderATaskAsDeadLocked, boolean deadLockedTasksKillingEnabled, boolean undestroyableFromExternal)
static QueuedTasksExecutor.Group	create(String name, Thread.Supplier threadSupplierForHighPriorityTasksExecutor, Thread.Supplier threadSupplierForNormalPriorityTasksExecutor, Thread.Supplier threadSupplierForLowPriorityTasksExecutor, boolean isDaemon, boolean undestroyableFromExternal)
static QueuedTasksExecutor.Group	create(String name, Thread.Supplier threadSupplierForHighPriorityTasksExecutor, Thread.Supplier threadSupplierForNormalPriorityTasksExecutor, Thread.Supplier threadSupplierForLowPriorityTasksExecutor, boolean isDaemon, long allTasksMonitoringInterval, long minimumElapsedTimeToConsiderATaskAsDeadLocked, boolean deadLockedTasksKillingEnabled)
QueuedTasksExecutor.Task	createTask(ThrowingRunnable<? extends Throwable> executable)
QueuedTasksExecutor.Task	createTask(ThrowingRunnable<? extends Throwable> executable, int priority)
<T> QueuedTasksExecutor.ProducerTask<T>	createTask(ThrowingSupplier<T,? extends Throwable> executable)
<T> QueuedTasksExecutor.ProducerTask<T>	createTask(ThrowingSupplier<T,? extends Throwable> executable, int priority)
Collection<QueuedTasksExecutor.TaskAbst<?,?>>	getAllTasksInExecution()
String	getInfoAsString()
boolean	isClosed()
QueuedTasksExecutor.Group	logInfo()
QueuedTasksExecutor.Group	setTasksCreationTrackingFlag(boolean flag)
boolean	shutDown(boolean waitForTasksTermination)
QueuedTasksExecutor.Group	startAllTasksMonitoring()
QueuedTasksExecutor.Group	startAllTasksMonitoring(QueuedTasksExecutor.Group.TasksMonitorer.Config config)
QueuedTasksExecutor.Group	stopAllTasksMonitoring()
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> QueuedTasksExecutor.Group	waitFor(T task, boolean ignoreDeadLocked)
<E, T extends QueuedTasksExecutor.TaskAbst<E, T>> QueuedTasksExecutor.Group	waitFor(T task, int priority, boolean ignoreDeadLocked)
QueuedTasksExecutor.Group	waitForTasksEnding()
QueuedTasksExecutor.Group	waitForTasksEnding(boolean ignoreDeadLocked)
QueuedTasksExecutor.Group	waitForTasksEnding(boolean waitForNewAddedTasks, boolean ignoreDeadLocked)
QueuedTasksExecutor.Group	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

Method Details

create

public static QueuedTasksExecutor.Group create(String name,
Thread.Supplier threadSupplierForHighPriorityTasksExecutor,
Thread.Supplier threadSupplierForNormalPriorityTasksExecutor,
Thread.Supplier threadSupplierForLowPriorityTasksExecutor,
boolean isDaemon,
long allTasksMonitoringInterval,
long minimumElapsedTimeToConsiderATaskAsDeadLocked,
boolean deadLockedTasksKillingEnabled)

create

public static QueuedTasksExecutor.Group create(String name,
Thread.Supplier threadSupplier,
boolean isDaemon,
long allTasksMonitoringInterval,
long minimumElapsedTimeToConsiderATaskAsDeadLocked,
boolean deadLockedTasksKillingEnabled,
boolean undestroyableFromExternal)

create

public static QueuedTasksExecutor.Group create(String name,
Thread.Supplier threadSupplierForHighPriorityTasksExecutor,
Thread.Supplier threadSupplierForNormalPriorityTasksExecutor,
Thread.Supplier threadSupplierForLowPriorityTasksExecutor,
boolean isDaemon,
boolean undestroyableFromExternal)

createTask

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

createTask

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

createTask

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

createTask

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

isClosed

public boolean isClosed()

waitForTasksEnding

public QueuedTasksExecutor.Group waitForTasksEnding()

waitForTasksEnding

public QueuedTasksExecutor.Group waitForTasksEnding(boolean ignoreDeadLocked)

waitForTasksEnding

public QueuedTasksExecutor.Group waitForTasksEnding(boolean waitForNewAddedTasks,
boolean ignoreDeadLocked)

waitForTasksEnding

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

waitFor

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

waitFor

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

setTasksCreationTrackingFlag

public QueuedTasksExecutor.Group setTasksCreationTrackingFlag(boolean flag)

logInfo

public QueuedTasksExecutor.Group logInfo()

getInfoAsString

public String getInfoAsString()

abort

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

getAllTasksInExecution

public Collection<QueuedTasksExecutor.TaskAbst<?,?>> getAllTasksInExecution()

startAllTasksMonitoring

public QueuedTasksExecutor.Group startAllTasksMonitoring(QueuedTasksExecutor.Group.TasksMonitorer.Config config)

startAllTasksMonitoring

public QueuedTasksExecutor.Group startAllTasksMonitoring()

stopAllTasksMonitoring

public QueuedTasksExecutor.Group stopAllTasksMonitoring()

shutDown

public boolean shutDown(boolean waitForTasksTermination)