th2-tasks-utils (0.1.4)

This library includes classes for managing tasks.

FutureTracker class

The class tracks futures and when needed tries to wait for them.

BlockingScheduledRetryableTaskQueue class

Queue with maximum task capacity, maximum total task data capacity and retry scheduler. Queue does not allow new tasks to exceed capacity limitations.

Task extraction order is determined by their schedule time, that is task with earlier schedule time will be extracted before the task with later schedule time. For equal schedule times no particular order is guarantied.

Task extraction does not free up resources in queue. They are reserved for future retries. Resources are only released on task completion.

Release notes

0.1.4

• The release includes BROKEN changes related to FutureTracker class:

  • The boolean track(CompletableFuture<T> future) method can throw InterruptedException.
  • The void awaitRemaining() and awaitRemaining(long timeoutMillis) methods can throw InterruptedException.

• Provided ability to limit capacity of FutureTracker class

• Added FutureTracker.createUnlimited() and FutureTracker.create(int limit) factory methods

• Added boolean track(CompletableFuture<T> future, Duration timeout) overload method in FutureTracker class.

• Added void awaitRemaining(Duration timeout) overload method in FutureTracker class.

• Added int limit() method into FutureTracker class.

• Added boolean hasLimit() method into FutureTracker class.

• Added boolean isEnabled() method into FutureTracker class.