Class ActivityRuntimeInfo

java.lang.Object

io.nosqlbench.engine.core.lifecycle.activity.ActivityRuntimeInfo

All Implemented Interfaces:

ProgressCapable

public class ActivityRuntimeInfo
extends Object
implements ProgressCapable

Constructor Summary

Constructors

Constructor	Description
ActivityRuntimeInfo(Activity activity, Future<ExecutionResult> result, ActivityExecutor executor)

Method Summary

Modifier and Type	Method	Description
boolean	awaitAllThreadsOnline(long timeoutMs)
ExecutionResult	awaitResult(long timeoutMillis)	Wait until the execution is complete and return the result.
void	forceStopActivity()
Activity	getActivity()
ActivityExecutor	getActivityExecutor()
Future<ExecutionResult>	getFuture()
ProgressMeterDisplay	getProgressMeter()
RunState	getRunState()
boolean	isRunning()
void	stopActivity()

Methods inherited from class java.lang.Object

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

Constructor Details

ActivityRuntimeInfo

public ActivityRuntimeInfo(Activity activity,
 Future<ExecutionResult> result,
 ActivityExecutor executor)

Method Details

getProgressMeter

public ProgressMeterDisplay getProgressMeter()

Specified by:

getProgressMeter in interface ProgressCapable

getFuture

public Future<ExecutionResult> getFuture()

awaitResult

public ExecutionResult awaitResult(long timeoutMillis)

Wait until the execution is complete and return the result.

Parameters:

timeoutMillis -

Returns:

null, or an ExecutionResult if the execution completed

Throws:

RuntimeException - if there was an execution exception

getActivity

public Activity getActivity()

isRunning

public boolean isRunning()

getRunState

public RunState getRunState()

stopActivity

public void stopActivity()

forceStopActivity

public void forceStopActivity()

getActivityExecutor

public ActivityExecutor getActivityExecutor()

awaitAllThreadsOnline

public boolean awaitAllThreadsOnline(long timeoutMs)