com.exalead.papi.framework.pipeline

Class OperationExecutor<SKey extends Key>

java.lang.Object

com.exalead.papi.framework.pipeline.OperationExecutor<SKey>

public class OperationExecutor<SKey extends Key>
extends java.lang.Object

Author:

Boiteux

Constructor Summary

Constructors

Constructor and Description
OperationExecutor(java.lang.String name, GenericMultiThreadedConnector<SKey> connector, int poolSize, int queueSize, java.lang.ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	addOperation(Operation<SKey> op)
void	addOperation(Operation<SKey>[] ops)
java.lang.String	getName()
int	getThreadCount()
void	setThreadcount(int nb)
void	start()
void	stop()
void	waitJobsCompleted()

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationExecutor

public OperationExecutor(java.lang.String name,
                         GenericMultiThreadedConnector<SKey> connector,
                         int poolSize,
                         int queueSize,
                         java.lang.ClassLoader classLoader)

Method Detail

start

public void start()

stop

public void stop()
          throws java.lang.Exception

Throws:

java.lang.Exception

getName

public java.lang.String getName()

setThreadcount

public void setThreadcount(int nb)

getThreadCount

public int getThreadCount()

addOperation

public void addOperation(Operation<SKey> op)

addOperation

public void addOperation(Operation<SKey>[] ops)

waitJobsCompleted

public void waitJobsCompleted()
                       throws java.lang.Exception

Throws:

java.lang.Exception