Interface TaskProcess


public interface TaskProcess
The task process. Used by the task to work with the running BatchRunnable
  • Method Details

    • getData

      TaskData getData()
      Get the data of the running BatchRunnable
      Returns:
      the data
    • next

      void next()
      Notify the next task
    • complete

      void complete()
      Notify the BatchRunnable to stop
    • getCurrentTaskPool

      TaskPool getCurrentTaskPool()
      Get the current task pool
      Returns:
      the current task pool
    • getTaskPool

      TaskPool getTaskPool(int stage)
      Get the task pool
      Parameters:
      stage - the stage of the task pool
      Returns:
      the task pool
    • addTaskPool

      default void addTaskPool(int stage, Consumer<TaskPool> taskPoolConsumer)
      Execute the consumer for the task pool
      Parameters:
      stage - the stage of the task pool
      taskPoolConsumer - the consumer
    • addCurrentTaskPool

      default void addCurrentTaskPool(Consumer<TaskPool> taskPoolConsumer)
      Execute the consumer for the current task pool
      Parameters:
      taskPoolConsumer - the consumer