net.yacy.kelondro.workflow

Class WorkflowProcessor<J extends WorkflowJob>

java.lang.Object

net.yacy.kelondro.workflow.WorkflowProcessor<J>

public class WorkflowProcessor<J extends WorkflowJob>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	availableCPU
private long	blockTime
private java.lang.String[]	childs
private java.lang.String	description
private java.lang.Object	environment
private long	execCount
private long	execTime
private java.util.concurrent.ExecutorService	executor
private java.util.concurrent.atomic.AtomicInteger	executorRunning
private java.util.concurrent.BlockingQueue<J>	input
private int	maxpoolsize
private java.lang.String	methodName
private WorkflowProcessor<J>	output
private long	passOnTime
private static java.util.ArrayList<WorkflowProcessor<?>>	processMonitor
private java.lang.String	processName

Constructor Summary

Constructors

Constructor and Description
WorkflowProcessor(java.lang.String name, java.lang.String description, java.lang.String[] childnames, java.lang.Object env, java.lang.String jobExecMethod, int inputQueueSize, WorkflowProcessor<J> output, int maxpoolsize)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
void	decExecutors() the decExecutors method may only be called within the AbstractBlockingThread while loop!!
void	enQueue(J in)
long	getBlockTime() the block time is the time that a take() blocks until it gets a value
java.lang.String	getChilds()
java.lang.String	getDescription()
java.lang.Object	getEnvironment()
long	getExecCount()
long	getExecTime() the exec time is the complete time of the execution and processing of the value from take()
int	getExecutors()
int	getMaxConcurrency()
int	getMaxQueueSize()
java.lang.String	getMethodName()
java.lang.String	getName()
long	getPassOnTime() the passOn time is the time that a put() takes to enqueue a result value to the next queue in case that the target queue is limited and may be full, this value may increase
int	getQueueSize()
protected void	increaseJobTime(long time)
void	passOn(J next)
static java.util.Iterator<WorkflowProcessor<?>>	processes()
boolean	queueIsEmpty()
private void	relaxCapacity()
void	shutdown()
J	take()

Methods inherited from class java.lang.Object

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

Field Detail

availableCPU

public static final int availableCPU

processMonitor

private static final java.util.ArrayList<WorkflowProcessor<?>> processMonitor

executor

private java.util.concurrent.ExecutorService executor

executorRunning

private java.util.concurrent.atomic.AtomicInteger executorRunning

input

private java.util.concurrent.BlockingQueue<J extends WorkflowJob> input

output

private final WorkflowProcessor<J extends WorkflowJob> output

maxpoolsize

private final int maxpoolsize

environment

private final java.lang.Object environment

processName

private final java.lang.String processName

methodName

private final java.lang.String methodName

description

private final java.lang.String description

childs

private final java.lang.String[] childs

blockTime

private long blockTime

execTime

private long execTime

passOnTime

private long passOnTime

execCount

private long execCount

Constructor Detail

WorkflowProcessor

public WorkflowProcessor(java.lang.String name,
                 java.lang.String description,
                 java.lang.String[] childnames,
                 java.lang.Object env,
                 java.lang.String jobExecMethod,
                 int inputQueueSize,
                 WorkflowProcessor<J> output,
                 int maxpoolsize)

Method Detail

getEnvironment

public java.lang.Object getEnvironment()

getMethodName

public java.lang.String getMethodName()

getQueueSize

public int getQueueSize()

queueIsEmpty

public boolean queueIsEmpty()

getMaxQueueSize

public int getMaxQueueSize()

getMaxConcurrency

public int getMaxConcurrency()

getExecutors

public int getExecutors()

decExecutors

public void decExecutors()

the decExecutors method may only be called within the AbstractBlockingThread while loop!!

take

public J take()
                           throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

passOn

public void passOn(J next)

clear

public void clear()

relaxCapacity

private void relaxCapacity()

enQueue

public void enQueue(J in)

shutdown

public void shutdown()

processes

public static java.util.Iterator<WorkflowProcessor<?>> processes()

increaseJobTime

protected void increaseJobTime(long time)

getName

public java.lang.String getName()

getDescription

public java.lang.String getDescription()

getChilds

public java.lang.String getChilds()

getBlockTime

public long getBlockTime()

the block time is the time that a take() blocks until it gets a value

Returns:

getExecTime

public long getExecTime()

the exec time is the complete time of the execution and processing of the value from take()

Returns:

getExecCount

public long getExecCount()

getPassOnTime

public long getPassOnTime()

the passOn time is the time that a put() takes to enqueue a result value to the next queue in case that the target queue is limited and may be full, this value may increase

Returns: