genius.core.session

Class ExecutorWithTimeout

java.lang.Object

genius.core.session.ExecutorWithTimeout

public class ExecutorWithTimeout
extends java.lang.Object

execute commands within the set timout limits. Compute and keeps remaining time for further calls. This executor can be called multiple times with different Callables so that the total accumulated time will stay within the total timeoutms that is given in the constructor. This executor will run a separate timer and kill the Callable with thread.stop() to make a pretty hard kill attempt if the time runs out.

Author:

W.Pasman, David Festen 1apr15

Constructor Summary

Constructors

Constructor and Description
ExecutorWithTimeout(long timeoutms) Construct an executor with a total available amount of time.

Method Summary

Modifier and Type	Method and Description
<V> V	execute(java.lang.String name, java.util.concurrent.Callable<V> command) Execute the command within the remaining time of this executor.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorWithTimeout

public ExecutorWithTimeout(long timeoutms)

Construct an executor with a total available amount of time.

Parameters:

timeoutms - the total available time that this executor can spend.

Method Detail

execute

public <V> V execute(java.lang.String name,
                     java.util.concurrent.Callable<V> command)
              throws java.util.concurrent.ExecutionException,
                     java.util.concurrent.TimeoutException

Execute the command within the remaining time of this executor. Blocking call. Used time will be subtracted from the quotum of this Executor. This function is synchronized and can execute only 1 Callable at any time.

Parameters:

name - the name of the thread/process/agent for which we are executing. Used for error reporting.

command - the Callable to execute

Returns:

the result V

Throws:

java.util.concurrent.ExecutionException - if the Callable threw an exception. The ExecutionException will contain the exception from the Callable.

java.util.concurrent.TimeoutException - if the Callable did not finish in time.