Uses of Class
org.apache.bookkeeper.common.util.OrderedScheduler

Packages that use OrderedScheduler

Package	Description
org.apache.bookkeeper.client	BookKeeper Client.
org.apache.bookkeeper.common.concurrent	Utility classes commonly useful in concurrent programming.
org.apache.bookkeeper.common.util	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 OrderedScheduler

Modifier and Type	Field	Description
(package private) final OrderedScheduler	BookKeeper.scheduler

Methods in org.apache.bookkeeper.client that return OrderedScheduler

Modifier and Type	Method	Description
(package private) OrderedScheduler	BookKeeper.getScheduler()
OrderedScheduler	ClientContext.getScheduler()

Uses of OrderedScheduler in org.apache.bookkeeper.common.concurrent

Methods in org.apache.bookkeeper.common.concurrent with parameters of type OrderedScheduler

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	FutureUtils.whenCompleteAsync(CompletableFuture<T> future, BiConsumer<? super T,? super Throwable> action, OrderedScheduler scheduler, Object scheduleKey)	Completing the future in the thread in the scheduler identified by the scheduleKey.
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 OrderedScheduler

Modifier and Type	Method	Description
OrderedScheduler	OrderedScheduler.SchedulerBuilder.build()

Methods in org.apache.bookkeeper.common.util with parameters of type OrderedScheduler

Modifier and Type	Method	Description
static <ReturnT> CompletableFuture<ReturnT>	Retries.run(Stream<Long> backoffs, Predicate<Throwable> retryPredicate, Supplier<CompletableFuture<ReturnT>> task, OrderedScheduler scheduler)	Retry a given task on failures.
static <ReturnT> CompletableFuture<ReturnT>	Retries.run(Stream<Long> backoffs, Predicate<Throwable> retryPredicate, Supplier<CompletableFuture<ReturnT>> task, OrderedScheduler scheduler, Object key)	Retry a given task on failures.