com.hof.mi.etl.runner

Class ETLBackgroundThreadManager

java.lang.Object

com.hof.mi.etl.runner.ETLBackgroundThreadManager

All Implemented Interfaces:

ETLThreadManager

public class ETLBackgroundThreadManager
extends java.lang.Object
implements ETLThreadManager

Implementation of the ETLThreadManager interface for managing threads for ETL Background Execution. It creates a Cached Thread Pool. The maximum pool size is the value passed into the constructor, unless it is lesser than #MIN_THREADS_FOR_CONCURRENCY.

Field Summary

Fields inherited from interface com.hof.mi.etl.runner.ETLThreadManager

MIN_THREADS_FOR_CONCURRENCY

Constructor Summary

Constructors

Constructor and Description
ETLBackgroundThreadManager(int maxThreads)

Method Summary

Methods

Modifier and Type	Method and Description
int	getMaxThreads() Get the maximum number of threads in the Thread Manager
void	shutdown() Shut down the Thread Manager.
java.util.concurrent.Future<java.lang.Void>	submit(ExecutionHead head) Submit a head task to the Thread Manager and return a Future.

Methods inherited from class java.lang.Object

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

Constructor Detail

ETLBackgroundThreadManager

public ETLBackgroundThreadManager(int maxThreads)

Method Detail

getMaxThreads

public int getMaxThreads()

Description copied from interface: ETLThreadManager

Get the maximum number of threads in the Thread Manager

Specified by:

getMaxThreads in interface ETLThreadManager

submit

public java.util.concurrent.Future<java.lang.Void> submit(ExecutionHead head)

Description copied from interface: ETLThreadManager

Submit a head task to the Thread Manager and return a Future.

Specified by:

submit in interface ETLThreadManager

Parameters:

head - - A runnable which can execute a "head" ETL step.

shutdown

public void shutdown()

Description copied from interface: ETLThreadManager

Shut down the Thread Manager.

Specified by:

shutdown in interface ETLThreadManager