Package org.apache.bookkeeper.common.util
package org.apache.bookkeeper.common.util
defines the utilities for allocator used across the project.
-
ClassDescriptionImplements various backoff strategies.A constant backoff policy.A exponential backoff policy.A Jittered backoff policy.Jitter type.Back off policy.Implements
ExecutorServiceand allows limiting the number of tasks to be scheduled in the thread's queue.ImplementsListeningScheduledExecutorServiceand allows limiting the number of tasks to be scheduled in the thread's queue.Utility to make it easier to add context to exception messages.Executor/Thread related utils.Util class which helps to parse Json to and from Object.A JSON parsing exception.A simple wrapper for aRunnablethat logs any exception thrown by it, before re-throwing it.Provides misc math functions that don't come standard.Utils for work with Slf4j MDC.Controller for tracking the amount of memory used for some task.This class supports submitting tasks with an ordering key, so that tasks submitted with the same key will always be executed in order, but tasks across different keys can be unordered.OrderedExecutor.AbstractBuilder<T extends OrderedExecutor>Abstract builder class to buildOrderedScheduler.A builder class for an OrderedExecutor.Decorator class for a callable that preserves MDC context.Decorator class for a runnable that preserves MDC context.This class provides supports submitting tasks with an ordering key, so that tasks submitted with the same key will always be executed in order, but tasks across different keys can be unordered.Builder to build ordered scheduler.An interface represents an object that is recyclable.An interface for indicating an object is reference counted.General Class Reflection Utils.A util class for supporting retries with customized backoff.A runnable that catches runtime exceptions.A holder for shared resource singletons.Defines a resource, and the way to create and destroy instances of it.Forked from Pulsar.Implements a single thread executor that drains the queue in batches to minimize contention between threads.JavaStreamrelated operations.Watchable<T>This class represents an watchable object, or "data" in the model-view paradigm.Watcher<T>A class can implement theWatcherinterface when it wants to be informed of one-time changes in watchable objects.