Package com.dua3.utility.concurrent

Class TaskProcessorAsync

java.lang.Object

com.dua3.utility.concurrent.TaskProcessorBase

com.dua3.utility.concurrent.TaskProcessorAsync

All Implemented Interfaces:

TaskProcessor

public class TaskProcessorAsync
extends TaskProcessorBase

TaskProcessor implementation where tasks are executed asynchronous using an ExecutorService.

When an instance is created, the number of maximum parallel tasks can be passed in.

Nested Class Summary

Nested classes/interfaces inherited from class com.dua3.utility.concurrent.TaskProcessorBase

TaskProcessorBase.State, TaskProcessorBase.Stats

Constructor Summary

Constructors

Constructor	Description
TaskProcessorAsync(String name, int maxThreads)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	shutdownAndAbort()	Shutdown and abort all submitted tasks.
<T> CompletableFuture<T>	submit(Callable<? extends T> task)	Submit a task that that returns a result.
boolean	waitForCompletion(long timeout, TimeUnit timeUnit)	Wait until all submitted tasks have completed or a timeout occurs.

Methods inherited from class com.dua3.utility.concurrent.TaskProcessorBase

addListener, ensureClosed, ensureOpen, getName, getState, getStats, isCompleted, isShutdown, newThreadFactory, nextId, registerId, registerParty, removeListener, shutdown, submit, terminate, unregisterId, unregisterParty

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.dua3.utility.concurrent.TaskProcessor

submitFuture

Constructor Details

TaskProcessorAsync

public TaskProcessorAsync(String name,
 int maxThreads)

Constructor.

Parameters:

name - this processor's name

maxThreads - maximal number of tasks that are executed parallel

Method Details

shutdownAndAbort

public void shutdownAndAbort()

Description copied from interface: TaskProcessor

Shutdown and abort all submitted tasks.

Specified by:

shutdownAndAbort in interface TaskProcessor

Overrides:

shutdownAndAbort in class TaskProcessorBase

waitForCompletion

public boolean waitForCompletion(long timeout,
 TimeUnit timeUnit)

Description copied from interface: TaskProcessor

Wait until all submitted tasks have completed or a timeout occurs.

Specified by:

waitForCompletion in interface TaskProcessor

Overrides:

waitForCompletion in class TaskProcessorBase

Parameters:

timeout - the timeout value

timeUnit - the unit to apply to the timeout value

Returns:

true, if all tasks have completed, otherwise false (timeout)

submit

public <T> CompletableFuture<T> submit(Callable<? extends T> task)

Description copied from interface: TaskProcessor

Submit a task that that returns a result.

Type Parameters:

T - the task result type

Parameters:

task - the task to execute

Returns:

a CompletableFuture for the task