com.kheops.util

Class TimeoutCommand<T>

java.lang.Object

com.kheops.util.TimeoutCommand<T>

Type Parameters:

T - the result type of execution execute

public class TimeoutCommand<T>
extends java.lang.Object

A command that returns a typed result and may throw an exception. Basically wraps around a callable task to monitor execution delay. Each task are run on a cached thread pool, will typically improve the performance of running many short-lived asynchronous tasks.

Constructor Summary

Constructors

Constructor and Description
TimeoutCommand()

Method Summary

Modifier and Type	Method and Description
void	destroy() Gracefully destroy opened resources.
T	execute(java.util.concurrent.Callable<T> task, long timeout, java.util.concurrent.TimeUnit unit) Executes a Callable interface with a timeout delay.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeoutCommand

public TimeoutCommand()

Method Detail

execute

public T execute(java.util.concurrent.Callable<T> task,
                 long timeout,
                 java.util.concurrent.TimeUnit unit)
          throws java.lang.Exception

Executes a Callable interface with a timeout delay. Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.

Parameters:

task - instructions to be executed

timeout - the maximum time to wait

unit - the time unit of the timeout argument

Returns:

typed result of the callable execution

Throws:

java.util.concurrent.TimeoutException - if the operation is not executed within the configured delay.

java.lang.Exception

destroy

public void destroy()

Gracefully destroy opened resources.