Uses of Class
org.apache.bookkeeper.common.util.OrderedScheduler
Packages that use OrderedScheduler
Package
Description
BookKeeper Client.
Utility classes commonly useful in concurrent programming.
defines the utilities for allocator used across the project.
-
Uses of OrderedScheduler in org.apache.bookkeeper.client
Fields in org.apache.bookkeeper.client declared as OrderedSchedulerMethods in org.apache.bookkeeper.client that return OrderedSchedulerModifier and TypeMethodDescription(package private) OrderedSchedulerBookKeeper.getScheduler()ClientContext.getScheduler() -
Uses of OrderedScheduler in org.apache.bookkeeper.common.concurrent
Methods in org.apache.bookkeeper.common.concurrent with parameters of type OrderedSchedulerModifier and TypeMethodDescriptionstatic <T> CompletableFuture<T>FutureUtils.whenCompleteAsync(CompletableFuture<T> future, BiConsumer<? super T, ? super Throwable> action, OrderedScheduler scheduler, Object scheduleKey) Completing thefuturein the thread in the scheduler identified by thescheduleKey.static <T> CompletableFuture<T>FutureUtils.within(CompletableFuture<T> promise, long timeout, TimeUnit unit, Throwable cause, OrderedScheduler scheduler, Object key) Raise an exception to the promise within a given timeout period. -
Uses of OrderedScheduler in org.apache.bookkeeper.common.util
Methods in org.apache.bookkeeper.common.util that return OrderedSchedulerMethods in org.apache.bookkeeper.common.util with parameters of type OrderedSchedulerModifier and TypeMethodDescriptionstatic <ReturnT> CompletableFuture<ReturnT>Retries.run(Stream<Long> backoffs, Predicate<Throwable> retryPredicate, Supplier<CompletableFuture<ReturnT>> task, OrderedScheduler scheduler) Retry a giventaskon failures.static <ReturnT> CompletableFuture<ReturnT>Retries.run(Stream<Long> backoffs, Predicate<Throwable> retryPredicate, Supplier<CompletableFuture<ReturnT>> task, OrderedScheduler scheduler, Object key) Retry a giventaskon failures.