edu.iu.dsc.tws.executor.threading

Class BatchSharingExecutor

java.lang.Object

edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

edu.iu.dsc.tws.executor.threading.BatchSharingExecutor

All Implemented Interfaces:

IExecutor, FaultAcceptable

Direct Known Subclasses:

DedidatedBatchExecutor

public class BatchSharingExecutor
extends ThreadSharingExecutor

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	notStopped

Fields inherited from class edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

channel, config, executionHook, executionPlan, numThreads, threads

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	closeExecution() Wait for the execution to complete
boolean	execute(boolean close) Execute the specific plan
boolean	isNotStopped()
boolean	runExecution() Execution Method for Batch Tasks
IExecution	runIExecution() Specific implementation needs to implement this method

Methods inherited from class edu.iu.dsc.tws.executor.threading.ThreadSharingExecutor

close, execute, getExecutionPlan, iExecute

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

Constructor Detail

BatchSharingExecutor

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

Method Detail

runExecution

public boolean runExecution()

Execution Method for Batch Tasks

Specified by:

runExecution in class ThreadSharingExecutor

Returns:

weather we executed successfully

execute

public boolean execute(boolean close)

Description copied from interface: IExecutor

Execute the specific plan

Returns:

true if accepted

isNotStopped

public boolean isNotStopped()

runIExecution

public IExecution runIExecution()

Description copied from class: ThreadSharingExecutor

Specific implementation needs to implement this method

Specified by:

runIExecution in class ThreadSharingExecutor

Returns:

weather we executed successfully

closeExecution

public boolean closeExecution()

Description copied from interface: IExecutor

Wait for the execution to complete

Returns:

true if successful