com.bigdata.counters

Class ActiveProcess

java.lang.Object

com.bigdata.counters.ActiveProcess

public class ActiveProcess
extends Object

Command manages the execution and termination of a native process and an object reading the output of that process.

Version:

$Id$

Author:

Bryan Thompson

Field Summary

Fields

Modifier and Type	Field and Description
protected InputStream	is
protected static org.apache.log4j.Logger	log
protected Process	process
protected Future	readerFuture
protected ExecutorService	readService Used to read is and aggregate the performance data reported by the process.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ActiveProcess()
	ActiveProcess(List<String> command, AbstractProcessCollector collector)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isAlive() Return true unless the process is known to be dead.
void	start(AbstractProcessReader processReader) Attaches the reader to the process, which was started by the ctor and is already running.
void	stop() Stops the process

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.log4j.Logger log

readService

protected final ExecutorService readService

Used to read is and aggregate the performance data reported by the process.

process

protected Process process

is

protected InputStream is

readerFuture

protected volatile Future readerFuture

Constructor Detail

ActiveProcess

protected ActiveProcess()

ActiveProcess

public ActiveProcess(List<String> command,
             AbstractProcessCollector collector)

Parameters:

command - The command to be executed. See ProcessBuilder.command(List).

collector -

Method Detail

start

public void start(AbstractProcessReader processReader)

Attaches the reader to the process, which was started by the ctor and is already running.

Parameters:

processReader - The reader.

stop

public void stop()

Stops the process

isAlive

public boolean isAlive()

Return true unless the process is known to be dead.