Package nl.knaw.dans.lib.util.pollingtaskexec

Interface TaskSource<R>

Type Parameters:
R - the type of the input used to create or schedule a task
public interface TaskSource<R>
Represents a source of tasks from which tasks can be fetched. Implementations of this interface are responsible for providing the logic to retrieve the next available input that represents one task to be executed, returning an empty Optional if no tasks are available. When invoked by PollingTaskExecutor, this method is run within a @UnitOfWork so that any updates it makes to the database are visible to the resulting tasks.

  • Method Summary

    Modifier and Type
    Method
    Description
    Optional<R>
    nextInput()
     

  • Method Details