Interface NonBlockingTaskEngine

  • All Superinterfaces:
    TaskEngine

    public interface NonBlockingTaskEngine
    extends TaskEngine
    Extends the TaskEngine interface to include additional methods allowing a task engine to have non blocking methods where as the mirrored methods on TaskEngine would block the invoking thread.
    • Method Detail

      • getTasksAsync

        CompletionStage<List<org.infinispan.tasks.Task>> getTasksAsync()
        Returns the list of tasks managed by this engine. This method will return immediately and the returned stage will now or some point in the future be completed with the list of tasks or an exception if something went wrong.
        Returns:
        stage containing the list of tasks when it is retrieved or an error
      • handlesAsync

        CompletionStage<Boolean> handlesAsync​(String taskName)
        Returns whether this task engine knows about a specified named task. This method will return immediately and the returned stage will now or some point in the future be completed with a Boolean whether this engine can perform this task or an exception if something went wrong
        Parameters:
        taskName - the task to check
        Returns:
        stage containing if the task can be handled or an error