dekoh.portal.fwk.importer
Class ExecutorBackedImportSubProcess

java.lang.Object
  dekoh.portal.fwk.importer.ExecutorBackedImportSubProcess

All Implemented Interfaces:

ImportSubProcess

Direct Known Subclasses:

DBOperationsSubProcess

public abstract class ExecutorBackedImportSubProcess
extends Object
implements ImportSubProcess

Since:

Mar 19, 2008

Nested Class Summary

Nested classes/interfaces inherited from interface dekoh.portal.fwk.importer.ImportSubProcess

ImportSubProcess.ExecutionPolicy

Constructor Summary

protected	ExecutorBackedImportSubProcess(String subProcessName, ImportSubProcessObserver importSubProcessObserver, ImportSubProcess.ExecutionPolicy policy, int noOfThreads)
protected	ExecutorBackedImportSubProcess(String subProcessName, ImportSubProcessObserver importSubProcessObserver, ImportSubProcess.ExecutionPolicy policy, long delay, TimeUnit timeUnit, int noOfThreads)

Method Summary

void	addSuccessor(ImportSubProcess successorImportTask)
void	awaitCompletion()
protected abstract Callable	createExecutionTask(ImportRequest importRequest, ImportSubProcessObserver actionObserver)
protected ScheduledThreadPoolExecutor	createExecutor(int coreSize)
void	execute(ImportRequest importRequest)
void	execute(ImportRequest importRequest, ImportSubProcessObserver actionObserver)
List	getSuccessors()
protected BlockingQueue	getTaskQueue()
protected int	getThreadPrority()
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorBackedImportSubProcess

protected ExecutorBackedImportSubProcess(String subProcessName,
                                         ImportSubProcessObserver importSubProcessObserver,
                                         ImportSubProcess.ExecutionPolicy policy,
                                         int noOfThreads)

ExecutorBackedImportSubProcess

protected ExecutorBackedImportSubProcess(String subProcessName,
                                         ImportSubProcessObserver importSubProcessObserver,
                                         ImportSubProcess.ExecutionPolicy policy,
                                         long delay,
                                         TimeUnit timeUnit,
                                         int noOfThreads)

Method Detail

execute

public void execute(ImportRequest importRequest)
             throws ExecutionException,
                    InterruptedException

Specified by:

execute in interface ImportSubProcess

Throws:

ExecutionException

InterruptedException

execute

public void execute(ImportRequest importRequest,
                    ImportSubProcessObserver actionObserver)
             throws ExecutionException,
                    InterruptedException

Specified by:

execute in interface ImportSubProcess

Throws:

ExecutionException

InterruptedException

shutdown

public void shutdown()

Specified by:

shutdown in interface ImportSubProcess

awaitCompletion

public void awaitCompletion()
                     throws InterruptedException,
                            ExecutionException

Specified by:

awaitCompletion in interface ImportSubProcess

Throws:

InterruptedException

ExecutionException

getTaskQueue

protected BlockingQueue getTaskQueue()

addSuccessor

public void addSuccessor(ImportSubProcess successorImportTask)

Specified by:

addSuccessor in interface ImportSubProcess

getSuccessors

public List getSuccessors()

Specified by:

getSuccessors in interface ImportSubProcess

createExecutor

protected ScheduledThreadPoolExecutor createExecutor(int coreSize)

getThreadPrority

protected int getThreadPrority()

createExecutionTask

protected abstract Callable createExecutionTask(ImportRequest importRequest,
                                                ImportSubProcessObserver actionObserver)