Class Runner

java.lang.Object

org.jgroups.util.Runner

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class Runner
extends Object
implements Runnable, Closeable

Runs a given function in a loop (in a separate thread) until it is stopped

Since:

4.0

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Runner.State

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	daemon
protected final ThreadFactory	factory
protected final Runnable	function
protected long	join_timeout
protected Log	log
protected Runner.State	state
protected final Runnable	stop_function
protected Thread	thread
protected String	thread_name

Constructor Summary

Constructors

Constructor	Description
Runner(String name, Runnable function, Runnable stop_function)
Runner(ThreadFactory factory, String thread_name, Runnable function, Runnable stop_function)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	daemon()
Runner	daemon(boolean d)
long	getJoinTimeout()
Thread	getThread()
boolean	isRunning()
Runner	joinTimeout(long t)
Log	log()
Runner	log(Log l)
void	run()
boolean	running()
protected void	runStopFunction()
Runner	setJoinTimeout(long t)
Runner	start()
Runner.State	state()
protected boolean	state(Runner.State new_state)
Runner	stop()
String	threadName()
Runner	threadName(String n)
String	toString()

Methods inherited from class Object

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

Field Details

factory

protected final ThreadFactory factory

thread_name

protected String thread_name

function

protected final Runnable function

stop_function

protected final Runnable stop_function

state

protected volatile Runner.State state

thread

protected Thread thread

daemon

protected boolean daemon

join_timeout

protected long join_timeout

log

protected Log log

Constructor Details

Runner

public Runner(String name,
 Runnable function,
 Runnable stop_function)

Runner

public Runner(ThreadFactory factory,
 String thread_name,
 Runnable function,
 Runnable stop_function)

Method Details

getThread

public Thread getThread()

isRunning

public boolean isRunning()

running

public boolean running()

state

public Runner.State state()

daemon

public boolean daemon()

daemon

public Runner daemon(boolean d)

threadName

public String threadName()

threadName

public Runner threadName(String n)

getJoinTimeout

public long getJoinTimeout()

setJoinTimeout

public Runner setJoinTimeout(long t)

joinTimeout

public Runner joinTimeout(long t)

log

public Log log()

log

public Runner log(Log l)

start

public Runner start()

stop

public Runner stop()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class Object

state

protected boolean state(Runner.State new_state)

runStopFunction

protected void runStopFunction()