net.yacy.kelondro.workflow

Class InstantBlockingThread<J extends WorkflowJob>

java.lang.Object

java.lang.Thread

net.yacy.kelondro.workflow.AbstractThread

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

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

All Implemented Interfaces:

java.lang.Runnable, BlockingThread<J>, WorkflowThread

public class InstantBlockingThread<J extends WorkflowJob>
extends AbstractBlockingThread<J>
implements BlockingThread<J>

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	BLOCKINGTHREAD
private java.lang.Object	environment
private java.lang.Long	handle
private static java.util.concurrent.atomic.AtomicInteger	handleCounter
private static java.util.concurrent.atomic.AtomicInteger	instantThreadCounter
private java.lang.reflect.Method	jobExecMethod
private static java.util.concurrent.ConcurrentMap<java.lang.Long,java.lang.String>	jobs

Fields inherited from class net.yacy.kelondro.workflow.AbstractThread

busytime, memuse, running

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
InstantBlockingThread(WorkflowProcessor<J> manager)

Method Summary

Methods

Modifier and Type	Method and Description
protected static java.lang.reflect.Method	execMethod(java.lang.Object env, java.lang.String jobExec)
int	getJobCount()
J	job(J next)

Methods inherited from class net.yacy.kelondro.workflow.AbstractBlockingThread

getManager, run, setManager

Methods inherited from class net.yacy.kelondro.workflow.AbstractThread

announceThreadBlockApply, announceThreadBlockRelease, close, getBlockTime, getExecTime, getLongDescription, getMemoryUse, getMonitorURL, getShortDescription, jobExceptionHandler, open, setDescription, shutdownInProgress, terminate

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.yacy.kelondro.workflow.BlockingThread

getManager, setManager

Methods inherited from interface net.yacy.kelondro.workflow.WorkflowThread

close, getBlockTime, getExecTime, getLongDescription, getMemoryUse, getMonitorURL, getShortDescription, isAlive, jobExceptionHandler, open, setDescription, shutdownInProgress, start, terminate

Field Detail

BLOCKINGTHREAD

private static final java.lang.String BLOCKINGTHREAD

See Also:

Constant Field Values

jobExecMethod

private final java.lang.reflect.Method jobExecMethod

environment

private final java.lang.Object environment

handle

private final java.lang.Long handle

handleCounter

private static java.util.concurrent.atomic.AtomicInteger handleCounter

instantThreadCounter

private static java.util.concurrent.atomic.AtomicInteger instantThreadCounter

jobs

private static final java.util.concurrent.ConcurrentMap<java.lang.Long,java.lang.String> jobs

Constructor Detail

InstantBlockingThread

public InstantBlockingThread(WorkflowProcessor<J> manager)

Method Detail

execMethod

protected static java.lang.reflect.Method execMethod(java.lang.Object env,
                                  java.lang.String jobExec)

getJobCount

public int getJobCount()

Specified by:

getJobCount in interface WorkflowThread

job

public J job(J next)
                          throws java.lang.Exception

Specified by:

job in interface BlockingThread<J extends WorkflowJob>

Throws:

java.lang.Exception