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

Class CombinedTaskScheduler

java.lang.Object
fr.ens.biologie.genomique.eoulsan.core.schedulers.CombinedTaskScheduler
All Implemented Interfaces:
TaskScheduler, Runnable
public class CombinedTaskScheduler extends Object implements TaskScheduler, Runnable
This class defined a combined task scheduler that use several context schedulers according to the parallelization mode of the step.
Since:
2.0
Author:
Laurent Jourdren

  • Constructor Details

    • CombinedTaskScheduler

      public CombinedTaskScheduler(int threadNumber)
      Constructor.
      Parameters:
      threadNumber - number of thread to use by the task scheduler

  • Method Details

    • submit

      public void submit(Step step, Set<TaskContextImpl> contexts)
      Description copied from interface: TaskScheduler
      Submit contexts to execute.
      Specified by:
      submit in interface TaskScheduler
      Parameters:
      step - step related to the contexts
      contexts - contexts to execute

    • submit

      public void submit(Step step, TaskContextImpl context)
      Description copied from interface: TaskScheduler
      Submit a context to execute.
      Specified by:
      submit in interface TaskScheduler
      Parameters:
      step - step related to the context
      context - context to execute

    • getStatus

      public StepStatus getStatus(Step step)
      Description copied from interface: TaskScheduler
      Get the status related to a step.
      Specified by:
      getStatus in interface TaskScheduler
      Parameters:
      step - a workflow step
      Returns:
      the step status object related to the step

    • getResult

      public StepResult getResult(Step step)
      Description copied from interface: TaskScheduler
      Get the result related to a step.
      Specified by:
      getResult in interface TaskScheduler
      Parameters:
      step - a workflow step
      Returns:
      the step result object related to the step

    • getTaskSubmittedCount

      public int getTaskSubmittedCount(Step step)
      Description copied from interface: TaskScheduler
      Get the count of submitted task contexts of a step.
      Specified by:
      getTaskSubmittedCount in interface TaskScheduler
      Parameters:
      step - a workflow step
      Returns:
      the count of submitted task contexts

    • getTaskRunningCount

      public int getTaskRunningCount(Step step)
      Description copied from interface: TaskScheduler
      Get the count of running task contexts of a step.
      Specified by:
      getTaskRunningCount in interface TaskScheduler
      Parameters:
      step - a workflow step
      Returns:
      the count of running task contexts

    • getTaskDoneCount

      public int getTaskDoneCount(Step step)
      Description copied from interface: TaskScheduler
      Get the count of done task contexts of a step.
      Specified by:
      getTaskDoneCount in interface TaskScheduler
      Parameters:
      step - a workflow step
      Returns:
      the count of done task contexts

    • waitEndOfTasks

      public void waitEndOfTasks(Step step)
      Description copied from interface: TaskScheduler
      Wait the end of the task contexts.
      Specified by:
      waitEndOfTasks in interface TaskScheduler
      Parameters:
      step - a workflow step

    • getTotalTaskSubmittedCount

      public int getTotalTaskSubmittedCount()
      Description copied from interface: TaskScheduler
      Get the count of submitted task contexts for the workflow.
      Specified by:
      getTotalTaskSubmittedCount in interface TaskScheduler
      Returns:
      the count of submitted task contexts

    • getTotalTaskRunningCount

      public int getTotalTaskRunningCount()
      Description copied from interface: TaskScheduler
      Get the count of running task contexts for the workflow.
      Specified by:
      getTotalTaskRunningCount in interface TaskScheduler
      Returns:
      the count of running task contexts

    • getTotalTaskDoneCount

      public int getTotalTaskDoneCount()
      Description copied from interface: TaskScheduler
      Get the count of done task contexts for the workflow.
      Specified by:
      getTotalTaskDoneCount in interface TaskScheduler
      Returns:
      the count of done task contexts

    • start

      public void start()
      Description copied from interface: TaskScheduler
      Start the scheduler.
      Specified by:
      start in interface TaskScheduler

    • stop

      public void stop()
      Description copied from interface: TaskScheduler
      Stop the scheduler.
      Specified by:
      stop in interface TaskScheduler

    • run

      public void run()
      Specified by:
      run in interface Runnable