Package adams.multiprocess

Interface Summary

Interface	Description
Job	A job is a unit of execution.
JobRunner<T extends Job>	Interface for runners that execute jobs.
JobRunnerHandler	Interface for classes that use a job runner.
JobRunnerSupporter	Interface for classes that can offload their processing into a jobs executed by a JobRunner instance.
JobWithOwner<T>	TODO: What class does.

Class Summary

Class	Description
AbstractJob	A job is a unit of execution.
AbstractJobRunner<T extends Job>	Ancestor for jobrunner classes.
AbstractMetaJobRunner	Ancestor for meta-jobrunners, that wrap around a base jobrunner.
CallableWithResult<T>	Callable that stores the result for future use.
JobList<T extends Job>	A container for jobs to execute.
JobResult	The result of Job Execution.
LocalJobRunner<T extends Job>	Executes the jobs on the local machine.
PausableFixedThreadPoolExecutor	The thread pool executor for the LocalJobRunner class.
RemoteCommandJobRunner	Utilizes the remote command framework for sending jobs to a remote machine.
RemoteCommandJobRunner.RemoteCommandGrabber	Handles the job response.
ScpJobRunner	Wraps another jobrunner and serializes it, scp's it to the specified remote file and then waits for the specified import file (containing the serialized, executed jobs) to appear. Requires a adams.flow.standalone.SSHConnection standalone for defining the SSH connection.
ScpJobRunner.RemoteJobRunner
SerializingJobRunner	Wraps another jobrunner and serializes it to the specified export file and then waits for the specified import file (containing the serialized, executed jobs) to appear.
WekaCrossValidationExecution	Performs cross-validation, either single or multi-threaded.
WekaCrossValidationJob	For evaluation of a single train/test fold in parallel.