compbio.engine.local

Class ExecutableWrapper

java.lang.Object

compbio.engine.local.ExecutableWrapper

All Implemented Interfaces:

java.util.concurrent.Callable<ConfiguredExecutable<?>>

@Immutable
public final class ExecutableWrapper
extends java.lang.Object
implements java.util.concurrent.Callable<ConfiguredExecutable<?>>

Field Summary

Fields

Modifier and Type	Field and Description
private ConfiguredExecutable<?>	confExec
private static java.util.concurrent.ExecutorService	es
private static org.apache.log4j.Logger	log
private java.lang.ProcessBuilder	pbuilder
static java.lang.String	PROC_ERR_FILE
static java.lang.String	PROC_IN_FILE
static java.lang.String	PROC_OUT_FILE

Constructor Summary

Constructors

Constructor and Description
ExecutableWrapper(ConfiguredExecutable<?> executable, java.lang.String workDirectory)

Method Summary

Modifier and Type	Method and Description
ConfiguredExecutable<?>	call() It is vital that output and error streams are captured immediately for this call() to succeed.
private java.lang.String	getError()
private java.lang.String	getOutput()
static void	shutdownService() Stops internal executor service which captures streams of native executables.

Methods inherited from class java.lang.Object

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

Field Detail

PROC_IN_FILE

public static final java.lang.String PROC_IN_FILE

See Also:

Constant Field Values

PROC_OUT_FILE

public static final java.lang.String PROC_OUT_FILE

See Also:

Constant Field Values

PROC_ERR_FILE

public static final java.lang.String PROC_ERR_FILE

See Also:

Constant Field Values

es

private static java.util.concurrent.ExecutorService es

confExec

private final ConfiguredExecutable<?> confExec

pbuilder

private final java.lang.ProcessBuilder pbuilder

log

private static final org.apache.log4j.Logger log

Constructor Detail

ExecutableWrapper

public ExecutableWrapper(ConfiguredExecutable<?> executable,
                         java.lang.String workDirectory)
                  throws JobSubmissionException

Throws:

JobSubmissionException

Method Detail

shutdownService

public static final void shutdownService()

Stops internal executor service which captures streams of native executables. This method is intended for stopping service if deployed in the web application content. There is NO NEED of using this method otherwise as the executor service is taken care of internally.

call

public ConfiguredExecutable<?> call()
                             throws java.io.IOException

It is vital that output and error streams are captured immediately for this call() to succeed. Thus each instance if ExecutableWrapper has 2 its own thread ready to capture the output. If executor could not execute capture immediately this could lead to the call method to stale, as execution could not proceed without output being captured. Every call to call() method will use 2 threads

Specified by:

call in interface java.util.concurrent.Callable<ConfiguredExecutable<?>>

Throws:

JobSubmissionException

java.io.IOException

getOutput

private java.lang.String getOutput()

getError

private java.lang.String getError()