Package fr.ens.biologie.genomique.eoulsan.core.schedulers.clusters

Class AbstractClusterTaskScheduler

java.lang.Object

fr.ens.biologie.genomique.eoulsan.core.schedulers.AbstractTaskScheduler

fr.ens.biologie.genomique.eoulsan.core.schedulers.clusters.AbstractClusterTaskScheduler

All Implemented Interfaces:

ClusterTaskScheduler, TaskScheduler

Direct Known Subclasses:

BpipeTaskScheduler

public abstract class AbstractClusterTaskScheduler
extends AbstractTaskScheduler
implements ClusterTaskScheduler

This class is a scheduler for task running on a cluster.

Since:

2.0

Author:

Laurent Jourdren

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	AbstractClusterTaskScheduler.ProcessThreadOutput	This class allow to fetch standard output or standard error.

Nested classes/interfaces inherited from interface fr.ens.biologie.genomique.eoulsan.core.schedulers.clusters.ClusterTaskScheduler

ClusterTaskScheduler.StatusResult, ClusterTaskScheduler.StatusValue

Constructor Summary

Constructors

Constructor	Description
AbstractClusterTaskScheduler()

Method Summary

Modifier and Type	Method	Description
void	stop()	Stop the scheduler.
void	submit(Step step, TaskContextImpl context)	Submit a context to execute.

Methods inherited from class fr.ens.biologie.genomique.eoulsan.core.schedulers.AbstractTaskScheduler

afterExecuteTask, beforeExecuteTask, executeTask, getResult, getStatus, getStep, getStep, getTaskDoneCount, getTaskRunningCount, getTaskSubmittedCount, getTotalTaskDoneCount, getTotalTaskRunningCount, getTotalTaskSubmittedCount, isStarted, isStopped, start, submit, waitEndOfTasks

Methods inherited from class java.lang.Object

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

Methods inherited from interface fr.ens.biologie.genomique.eoulsan.core.schedulers.clusters.ClusterTaskScheduler

cleanupJob, configure, getSchedulerName, statusJob, stopJob, submitJob

Methods inherited from interface fr.ens.biologie.genomique.eoulsan.core.schedulers.TaskScheduler

getResult, getStatus, getTaskDoneCount, getTaskRunningCount, getTaskSubmittedCount, getTotalTaskDoneCount, getTotalTaskRunningCount, getTotalTaskSubmittedCount, start, submit, waitEndOfTasks

Constructor Detail

AbstractClusterTaskScheduler

public AbstractClusterTaskScheduler()

Method Detail

submit

public void submit(Step step,
                   TaskContextImpl context)

Description copied from interface: TaskScheduler

Submit a context to execute.

Specified by:

submit in interface TaskScheduler

Overrides:

submit in class AbstractTaskScheduler

Parameters:

step - step related to the context

context - context to execute

stop

public void stop()

Description copied from interface: TaskScheduler

Stop the scheduler.

Specified by:

stop in interface TaskScheduler

Overrides:

stop in class AbstractTaskScheduler