edu.iu.dsc.tws.executor.threading

Class BatchSharingExecutor2

java.lang.Object

edu.iu.dsc.tws.executor.threading.BatchSharingExecutor2

All Implemented Interfaces:

IExecutor, FaultAcceptable

Direct Known Subclasses:

AllSharingBatchExecutor

public class BatchSharingExecutor2
extends java.lang.Object
implements IExecutor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	BatchSharingExecutor2.BatchWorker
protected class	BatchSharingExecutor2.CommunicationWorker

Field Summary

Fields

Modifier and Type	Field and Description
protected IExecutionHook	executionHook The execution hook
protected boolean	notStopped
protected ExecutionPlan	plan The current plan we are executing

Constructor Summary

Constructors

Constructor and Description
BatchSharingExecutor2(Config cfg, int workerId, TWSChannel channel, ExecutionPlan plan, IExecutionHook hook)

Method Summary

Modifier and Type	Method and Description
void	close() Terminate the executor
boolean	closeExecution() Wait for the execution to complete
boolean	execute() Execute the specific plan
boolean	execute(boolean close) Execute the specific plan
ExecutionPlan	getExecutionPlan() Get the execution plan associated with this executor
IExecution	iExecute() Asynchronously execute a plan, One need to call progress on the execution object returned to continue the execution
boolean	isNotStopped()
boolean	runExecution(ExecutionPlan executionPlan) Execution Method for Batch Tasks
IExecution	runIExecution()

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.iu.dsc.tws.api.compute.executor.IExecutor

onFault

Field Detail

notStopped

protected boolean notStopped

plan

protected ExecutionPlan plan

The current plan we are executing

executionHook

protected IExecutionHook executionHook

The execution hook

Constructor Detail

BatchSharingExecutor2

public BatchSharingExecutor2(Config cfg,
                             int workerId,
                             TWSChannel channel,
                             ExecutionPlan plan,
                             IExecutionHook hook)

Method Detail

execute

public boolean execute()

Description copied from interface: IExecutor

Execute the specific plan

Specified by:

execute in interface IExecutor

Returns:

true if accepted

iExecute

public IExecution iExecute()

Description copied from interface: IExecutor

Asynchronously execute a plan, One need to call progress on the execution object returned to continue the execution

Specified by:

iExecute in interface IExecutor

Returns:

an execution or null if not accepted

execute

public boolean execute(boolean close)

Description copied from interface: IExecutor

Execute the specific plan

Specified by:

execute in interface IExecutor

Returns:

true if accepted

close

public void close()

Description copied from interface: IExecutor

Terminate the executor

Specified by:

close in interface IExecutor

isNotStopped

public boolean isNotStopped()

getExecutionPlan

public ExecutionPlan getExecutionPlan()

Description copied from interface: IExecutor

Get the execution plan associated with this executor

Specified by:

getExecutionPlan in interface IExecutor

Returns:

the execution plan

runExecution

public boolean runExecution(ExecutionPlan executionPlan)

Execution Method for Batch Tasks

runIExecution

public IExecution runIExecution()

closeExecution

public boolean closeExecution()

Description copied from interface: IExecutor

Wait for the execution to complete

Specified by:

closeExecution in interface IExecutor

Returns:

true if successful