com.enremmeta.rtb

Class FutureTestTemplate<T,I>

java.lang.Object

com.enremmeta.rtb.FutureTestTemplate<T,I>

Direct Known Subclasses:

DynamoDBFutureSpec_ALL, JsonFutureSpec_ALL

public abstract class FutureTestTemplate<T,I>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private ExecutorService	executor
private long	maxTimeWaitTermination
private long	taskTimeout
private Future<T>	testFuture

Constructor Summary

Constructors

Constructor and Description
FutureTestTemplate()

Method Summary

Modifier and Type	Method and Description
protected abstract Future<T>	createTestFuture(Future<I> innerFuture)
protected Future<T>	getTestFuture()
protected void	set_up()
protected void	tear_down()
protected void	test_cancel_ifTaskIsFinished()
protected void	test_cancel_ifTaskIsRunning()
protected T	test_get(I innerFutureGetResult)
protected void	test_getWithTimeout_ifWaitTimeElapsed(I innerFutureGetResult)
protected T	test_getWithTimeout(I innerFutureGetResult)

Methods inherited from class java.lang.Object

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

Field Detail

executor

private ExecutorService executor

maxTimeWaitTermination

private long maxTimeWaitTermination

taskTimeout

private long taskTimeout

testFuture

private Future<T> testFuture

Constructor Detail

FutureTestTemplate

public FutureTestTemplate()

Method Detail

getTestFuture

protected Future<T> getTestFuture()

set_up

protected void set_up()

tear_down

protected void tear_down()
                  throws InterruptedException

Throws:

InterruptedException

createTestFuture

protected abstract Future<T> createTestFuture(Future<I> innerFuture)

test_cancel_ifTaskIsFinished

protected void test_cancel_ifTaskIsFinished()
                                     throws InterruptedException,
                                            ExecutionException

Throws:

InterruptedException

ExecutionException

test_cancel_ifTaskIsRunning

protected void test_cancel_ifTaskIsRunning()

test_get

protected T test_get(I innerFutureGetResult)
              throws InterruptedException,
                     ExecutionException

Throws:

InterruptedException

ExecutionException

test_getWithTimeout

protected T test_getWithTimeout(I innerFutureGetResult)
                         throws InterruptedException,
                                ExecutionException,
                                TimeoutException

Throws:

InterruptedException

ExecutionException

TimeoutException

test_getWithTimeout_ifWaitTimeElapsed

protected void test_getWithTimeout_ifWaitTimeElapsed(I innerFutureGetResult)
                                              throws InterruptedException,
                                                     ExecutionException,
                                                     TimeoutException

Throws:

InterruptedException

ExecutionException

TimeoutException