com.exalead.papi.framework.pipeline

Class OperationPipelinesManager<SKey extends Key>

java.lang.Object

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

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

Field Summary

Fields

Modifier and Type	Field and Description
protected GenericMultiThreadedConnector<SKey>	connector
protected OperationExecutor<SKey>	m_DocumentOperationPipeline
protected OperationExecutor<SKey>	m_FolderOperationPipeline
protected java.lang.String	name

Constructor Summary

Constructors

Constructor and Description
OperationPipelinesManager(java.lang.String name, GenericMultiThreadedConnector<SKey> connector, int sourceCountThread, int operationCountThread, int maxDocQueued, int maxFolderQueued, java.lang.ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	addDocumentOperation(DocumentOperation<SKey> op)
void	addDocumentoperation(DocumentOperation<SKey>[] op)
void	addFolderOperation(FolderOperation<SKey> op)
void	addFolderOperation(FolderOperation<SKey>[] op)
int	getNbThreadsPerDocumentOperationPipeline()
int	getNbThreadsPerFolderOperationPipeline()
void	setNbThreadsPerDocumentOperationPipeline(int nb)
void	setNbThreadsPerFolderOperationPipeline(int nb)
void	terminateThreads()
void	waitForDocumentOperationPipelineTreatmentCompleted()
void	waitForFolderOperationPipelineTreatmentCompleted()

Methods inherited from class java.lang.Object

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

Field Detail

m_FolderOperationPipeline

protected OperationExecutor<SKey extends Key> m_FolderOperationPipeline

m_DocumentOperationPipeline

protected OperationExecutor<SKey extends Key> m_DocumentOperationPipeline

connector

protected GenericMultiThreadedConnector<SKey extends Key> connector

name

protected java.lang.String name

Constructor Detail

OperationPipelinesManager

public OperationPipelinesManager(java.lang.String name,
                                 GenericMultiThreadedConnector<SKey> connector,
                                 int sourceCountThread,
                                 int operationCountThread,
                                 int maxDocQueued,
                                 int maxFolderQueued,
                                 java.lang.ClassLoader classLoader)
                          throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getNbThreadsPerFolderOperationPipeline

public int getNbThreadsPerFolderOperationPipeline()

getNbThreadsPerDocumentOperationPipeline

public int getNbThreadsPerDocumentOperationPipeline()

setNbThreadsPerDocumentOperationPipeline

public void setNbThreadsPerDocumentOperationPipeline(int nb)

setNbThreadsPerFolderOperationPipeline

public void setNbThreadsPerFolderOperationPipeline(int nb)

addFolderOperation

public void addFolderOperation(FolderOperation<SKey> op)
                        throws java.lang.Exception

Throws:

java.lang.Exception

addFolderOperation

public void addFolderOperation(FolderOperation<SKey>[] op)
                        throws java.lang.Exception

Throws:

java.lang.Exception

addDocumentOperation

public void addDocumentOperation(DocumentOperation<SKey> op)
                          throws java.lang.Exception

Throws:

java.lang.Exception

addDocumentoperation

public void addDocumentoperation(DocumentOperation<SKey>[] op)
                          throws java.lang.Exception

Throws:

java.lang.Exception

waitForFolderOperationPipelineTreatmentCompleted

public void waitForFolderOperationPipelineTreatmentCompleted()
                                                      throws java.lang.Exception

Throws:

java.lang.Exception

waitForDocumentOperationPipelineTreatmentCompleted

public void waitForDocumentOperationPipelineTreatmentCompleted()
                                                        throws java.lang.Exception

Throws:

java.lang.Exception

terminateThreads

public void terminateThreads()
                      throws java.lang.Exception

Throws:

java.lang.Exception