compbio.engine.local

Class LocalRunner

java.lang.Object

compbio.engine.local.LocalRunner

All Implemented Interfaces:

SyncExecutor

public final class LocalRunner
extends java.lang.Object
implements SyncExecutor

Field Summary

Fields

Modifier and Type	Field and Description
private ConfiguredExecutable<?>	executable
private java.util.concurrent.ExecutorService	executor
private java.util.concurrent.Future<ConfiguredExecutable<?>>	future
private static org.apache.log4j.Logger	log
private java.lang.String	workDirectory

Constructor Summary

Constructors

Constructor and Description
LocalRunner(ConfiguredExecutable<?> executable)

Method Summary

Modifier and Type	Method and Description
boolean	cancelJob() Stops running job.
boolean	cleanup() Clean up after the job
void	executeJob() Execute the job
(package private) java.util.concurrent.Future<ConfiguredExecutable<?>>	getFuture()
JobStatus	getJobStatus() Query the status of the job by its id.
java.lang.String	getWorkDirectory()
ConfiguredExecutable<?>	waitForResult() Call to this method block for as long as it is required for an executable to finish its job.

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.apache.log4j.Logger log

executor

private final java.util.concurrent.ExecutorService executor

executable

private final ConfiguredExecutable<?> executable

future

private java.util.concurrent.Future<ConfiguredExecutable<?>> future

workDirectory

private final java.lang.String workDirectory

Constructor Detail

LocalRunner

public LocalRunner(ConfiguredExecutable<?> executable)

Method Detail

getWorkDirectory

public java.lang.String getWorkDirectory()

Specified by:

getWorkDirectory in interface SyncExecutor

Returns:

working directory if the task

cancelJob

public boolean cancelJob()

Description copied from interface: SyncExecutor

Stops running job. Clean up is not performed.

Specified by:

cancelJob in interface SyncExecutor

Returns:

true if job was cancelled successfully, false otherwise

getFuture

java.util.concurrent.Future<ConfiguredExecutable<?>> getFuture()

getJobStatus

public JobStatus getJobStatus()

Description copied from interface: SyncExecutor

Query the status of the job by its id.

Specified by:

getJobStatus in interface SyncExecutor

Returns:

- JobStatus

executeJob

public void executeJob()
                throws JobSubmissionException

Description copied from interface: SyncExecutor

Execute the job

Specified by:

executeJob in interface SyncExecutor

Throws:

JobSubmissionException - if submission fails

waitForResult

public ConfiguredExecutable<?> waitForResult()
                                      throws JobExecutionException

Description copied from interface: SyncExecutor

Call to this method block for as long as it is required for an executable to finish its job. If the calculation has been completed already, the this method returns results immediately. This could return the result directly, but that would be type unsafe

Specified by:

waitForResult in interface SyncExecutor

Returns:

object from wich the result can be obtained

Throws:

java.util.concurrent.CancellationException

JobExecutionException

cleanup

public boolean cleanup()

Description copied from interface: SyncExecutor

Clean up after the job

Specified by:

cleanup in interface SyncExecutor

Returns:

true if all the files created by this job have been removed successfully, false otherwise