org.dice_research.topicmodeling.concurrent.reporter

Class WaitingThreadInterrupter

java.lang.Object

org.dice_research.topicmodeling.concurrent.reporter.AbstractReporter

org.dice_research.topicmodeling.concurrent.reporter.WaitingThreadInterrupter

All Implemented Interfaces:

Runnable, Reporter, TaskStateReporter, TaskObserver

public class WaitingThreadInterrupter
extends AbstractReporter
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_TIME_INTERVAL
private static org.slf4j.Logger	LOGGER
private long	maximumWaitingTime
private static String	THREAD_NAME
private long	timeInterval

Constructor Summary

Constructors

Constructor and Description
WaitingThreadInterrupter(Overseer overseer, long maximumWaitingTime)
WaitingThreadInterrupter(Overseer overseer, long maximumWaitingTime, long timeInterval)

Method Summary

Modifier and Type	Method and Description
long	getMaximumWaitingTime()
void	reportTaskState(TaskState state)
void	run()
void	setMaximumWaitingTime(long maximumWaitingTime)

Methods inherited from class org.dice_research.topicmodeling.concurrent.reporter.AbstractReporter

getOverseer, reportCurrentState, reportTaskFinished, reportTaskThrowedException, setOverseer

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFAULT_TIME_INTERVAL

public static final long DEFAULT_TIME_INTERVAL

See Also:

Constant Field Values

THREAD_NAME

private static final String THREAD_NAME

See Also:

Constant Field Values

timeInterval

private long timeInterval

maximumWaitingTime

private long maximumWaitingTime

Constructor Detail

WaitingThreadInterrupter

public WaitingThreadInterrupter(Overseer overseer,
                                long maximumWaitingTime,
                                long timeInterval)

WaitingThreadInterrupter

public WaitingThreadInterrupter(Overseer overseer,
                                long maximumWaitingTime)

Method Detail

reportTaskState

public void reportTaskState(TaskState state)

Specified by:

reportTaskState in interface TaskStateReporter

run

public void run()

Specified by:

run in interface Runnable

getMaximumWaitingTime

public long getMaximumWaitingTime()

Returns:

the maximumWaitingTime

setMaximumWaitingTime

public void setMaximumWaitingTime(long maximumWaitingTime)

Parameters:

maximumWaitingTime - the maximumWaitingTime to set