org.finra.datagenerator.distributor.multithreaded

Class DefaultDistributor

java.lang.Object

org.finra.datagenerator.distributor.multithreaded.DefaultDistributor

All Implemented Interfaces:

SearchDistributor

public class DefaultDistributor
extends Object
implements SearchDistributor

Created by robbinbr on 3/24/14.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log Logger

Constructor Summary

Constructors

Constructor and Description
DefaultDistributor()

Method Summary

Methods

Modifier and Type	Method and Description
void	distribute(List<Frontier> frontierList) Distributes the list of the problems
SearchDistributor	setDataConsumer(DataConsumer dataConsumer) Sets the data consumer
void	setFlag(String name, AtomicBoolean flag) TODO: Buggy !! this function is adding a new instance of AromicBoolen and not setting the value of a current atomic boolean
DefaultDistributor	setMaxNumberOfLines(long numberOfLines) Sets the maximum number of lines to generate
DefaultDistributor	setThreadCount(int threadCount) Sets the number of threads to use

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

Logger

Constructor Detail

DefaultDistributor

public DefaultDistributor()

Method Detail

setMaxNumberOfLines

public DefaultDistributor setMaxNumberOfLines(long numberOfLines)

Sets the maximum number of lines to generate

Parameters:

numberOfLines - a long containing the maximum number of lines to generate

Returns:

a reference to the current DefaultDistributor

setThreadCount

public DefaultDistributor setThreadCount(int threadCount)

Sets the number of threads to use

Parameters:

threadCount - an int containing the thread count

Returns:

a reference to the current DefaultDistributor

setDataConsumer

public SearchDistributor setDataConsumer(DataConsumer dataConsumer)

Description copied from interface: SearchDistributor

Sets the data consumer

Specified by:

setDataConsumer in interface SearchDistributor

Parameters:

dataConsumer - the DataConsumer

Returns:

a reference to the current SearchDistributor

distribute

public void distribute(List<Frontier> frontierList)

Description copied from interface: SearchDistributor

Distributes the list of the problems

Specified by:

distribute in interface SearchDistributor

Parameters:

frontierList - a list containing the search problems to distribute

setFlag

public void setFlag(String name,
           AtomicBoolean flag)

Description copied from interface: SearchDistributor

TODO: Buggy !! this function is adding a new instance of AromicBoolen and not setting the value of a current atomic boolean

Specified by:

setFlag in interface SearchDistributor

Parameters:

name - the name of the flag

flag - the value of the flag