Package nz.org.riskscape.engine.sched

Class ExecutionFuture

java.lang.Object
nz.org.riskscape.engine.sched.ExecutionFuture
public class ExecutionFuture extends Object

Wraps a CompletableFuture for jobs queued up on the Scheduler, mostly for historic reasons. Also has some job management code for use by the Scheduler (hence the package scope on some methods).

Using a CompletableFuture allows callers to chain async actions via thenApply, thenCompose, etc. once the pipeline has finished.

  • Constructor Details

    • ExecutionFuture

      public ExecutionFuture(nz.org.riskscape.engine.output.PipelineJobContext jobContext)

  • Method Details

    • getJobContext

      public nz.org.riskscape.engine.output.PipelineJobContext getJobContext()

    • getFuture

      public CompletableFuture<nz.org.riskscape.engine.pipeline.ExecutionResult> getFuture()

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • canEqual

      protected boolean canEqual(Object other)

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object