org.rvpf.service

Class ThreadExecutor

Object

ThreadExecutor

All Implemented Interfaces:

Runnable, Executor, ExecutorService

@ThreadSafe
public class ThreadExecutor
extends Object
implements ExecutorService, Runnable

Thread executor.

Constructor Summary

Constructors

Constructor and Description
ThreadExecutor(Optional<Logger> logger) Constructs an instance.

Method Summary

Modifier and Type	Method and Description
boolean	awaitTermination(long timeout, TimeUnit unit)
void	execute(Runnable runnable)
<T> T	invoke(Callable<T> callable) Invokes a callable from inside the thread.
<T> T	invoke(Callable<T> callable, long timeout, TimeUnit unit) Invokes a callable from inside the thread.
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> callables)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> callables, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> callables)
<T> T	invokeAny(Collection<? extends Callable<T>> callables, long timeout, TimeUnit unit)
boolean	isBusy() Asks if this executor is busy.
boolean	isRunning() Asks if this executor is running.
boolean	isShutdown()
boolean	isTerminated()
void	reset(Optional<String> threadName, boolean daemonThread) Resets.
void	run()
void	shutdown()
List<Runnable>	shutdownNow()
void	startThread() Starts the thread.
<T> Future<T>	submit(Callable<T> callable)
Future<?>	submit(Runnable runnable)
<T> Future<T>	submit(Runnable runnable, T result)

Methods inherited from class Object

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

Constructor Detail

ThreadExecutor

public ThreadExecutor(@Nonnull
                      Optional<Logger> logger)

Constructs an instance.

Parameters:

logger - An optional logger.

Method Detail

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in interface ExecutorService

Throws:

InterruptedException

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor

invoke

@CheckReturnValue
public <T> T invoke(@Nonnull
                                       Callable<T> callable)
                                throws InterruptedException,
                                       ExecutionException

Invokes a callable from inside the thread.

Type Parameters:

T - The type returned by the callable.

Parameters:

callable - The callable.

Returns:

The value returned by the callable.

Throws:

InterruptedException - When the invoke is interrupted.

ExecutionException - When the callable throws something.

invoke

@CheckReturnValue
public <T> T invoke(Callable<T> callable,
                                       long timeout,
                                       TimeUnit unit)
                                throws InterruptedException,
                                       ExecutionException,
                                       TimeoutException

Invokes a callable from inside the thread.

Type Parameters:

T - The type returned by the callable.

Parameters:

callable - The callable.

timeout - The maximum time to wait.

unit - The time ounit of the timeout.

Returns:

The value returned by the callable.

Throws:

InterruptedException - When the invoke is interrupted.

ExecutionException - When the callable throws something.

TimeoutException - If the timeout elapses.

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables,
                                     long timeout,
                                     TimeUnit unit)
                              throws InterruptedException

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> callables)
                throws InterruptedException,
                       ExecutionException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> callables,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

Specified by:

invokeAny in interface ExecutorService

Throws:

InterruptedException

ExecutionException

TimeoutException

isBusy

@CheckReturnValue
public boolean isBusy()

Asks if this executor is busy.

Returns:

True if busy.

isRunning

@CheckReturnValue
public boolean isRunning()

Asks if this executor is running.

Returns:

True if running.

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface ExecutorService

reset

public void reset(@Nonnull
                  Optional<String> threadName,
                  boolean daemonThread)

Resets.

Parameters:

threadName - The optional thread name.

daemonThread - Sets the thread as daemon if true.

run

public void run()

Specified by:

run in interface Runnable

shutdown

public void shutdown()

Specified by:

shutdown in interface ExecutorService

shutdownNow

public List<Runnable> shutdownNow()

Specified by:

shutdownNow in interface ExecutorService

startThread

public void startThread()

Starts the thread.

submit

public <T> Future<T> submit(Callable<T> callable)

Specified by:

submit in interface ExecutorService

submit

public Future<?> submit(Runnable runnable)

Specified by:

submit in interface ExecutorService

submit

public <T> Future<T> submit(Runnable runnable,
                            T result)

Specified by:

submit in interface ExecutorService