edu.iu.dsc.tws.executor.threading

Class ThreadSharingExecutor

java.lang.Object

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

All Implemented Interfaces:

IExecutor, FaultAcceptable

Direct Known Subclasses:

BatchSharingExecutor, StreamingSharingExecutor

public abstract class ThreadSharingExecutor
extends java.lang.Object
implements IExecutor

Abstract class for thread sharing executors

Field Summary

Fields

Modifier and Type	Field and Description
protected TWSChannel	channel Channel
protected Config	config The configuration
protected IExecutionHook	executionHook The execution hook
protected ExecutionPlan	executionPlan Execution plan
protected int	numThreads Number of threads
protected java.util.concurrent.ExecutorService	threads Thread service

Constructor Summary

Constructors

Constructor and Description
ThreadSharingExecutor(Config config, TWSChannel ch, ExecutionPlan plan, IExecutionHook hook)

Method Summary

Modifier and Type	Method and Description
void	close() Terminate the executor
boolean	execute() 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
abstract boolean	runExecution() Specific implementation needs to implement this method
abstract IExecution	runIExecution() Specific implementation needs to implement this method

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

closeExecution, execute, onFault

Field Detail

numThreads

protected int numThreads

Number of threads

threads

protected java.util.concurrent.ExecutorService threads

Thread service

channel

protected TWSChannel channel

Channel

config

protected Config config

The configuration

executionPlan

protected ExecutionPlan executionPlan

Execution plan

executionHook

protected IExecutionHook executionHook

The execution hook

Constructor Detail

ThreadSharingExecutor

public ThreadSharingExecutor(Config config,
                             TWSChannel ch,
                             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

runExecution

public abstract boolean runExecution()

Specific implementation needs to implement this method

Returns:

weather we executed successfully

runIExecution

public abstract IExecution runIExecution()

Specific implementation needs to implement this method

Returns:

weather we executed successfully

close

public void close()

Description copied from interface: IExecutor

Terminate the executor

Specified by:

close in interface IExecutor

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