org.apache.reef.runtime.local.process

Class RunnableProcess

java.lang.Object

org.apache.reef.runtime.local.process.RunnableProcess

All Implemented Interfaces:

Runnable

public final class RunnableProcess
extends Object
implements Runnable

A runnable class that encapsulates a process.

Constructor Summary

Constructors

Constructor and Description
RunnableProcess(List<String> command, String id, File folder, RunnableProcessObserver processObserver, String standardOutFileName, String standardErrorFileName)

Method Summary

Methods

Modifier and Type	Method and Description
void	cancel() Cancels the running process if it is running.
void	run() Runs the configured process.

Methods inherited from class java.lang.Object

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

Constructor Detail

RunnableProcess

public RunnableProcess(List<String> command,
               String id,
               File folder,
               RunnableProcessObserver processObserver,
               String standardOutFileName,
               String standardErrorFileName)

Parameters:

command - the command to execute.

id - The ID of the process. This is used to name files and in the logs created by this process.

folder - The folder in which this will store its stdout and stderr output

processObserver - will be informed of process state changes.

standardOutFileName - The name of the file used for redirecting STDOUT

standardErrorFileName - The name of the file used for redirecting STDERR

Method Detail

run

public void run()

Runs the configured process.

Specified by:

run in interface Runnable

Throws:

IllegalStateException - if the process is already running or has been running before.

cancel

public void cancel()

Cancels the running process if it is running.