Uses of Package
org.jgroups.util

Packages that use org.jgroups.util

Package	Description
org.jgroups	Provides top-level public JGroups classes such as Channel, Message, etc.
org.jgroups.auth
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.cs	This package contains all client-server related interfaces and classes
org.jgroups.blocks.executor
org.jgroups.blocks.locking
org.jgroups.blocks.mux
org.jgroups.conf	Provides ways to configure a protocol stack.
org.jgroups.demos	Provides demonstrations of JGroups functionality.
org.jgroups.fork
org.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
org.jgroups.protocols.pbcast	Supports probabilistic broadcasts.
org.jgroups.protocols.relay
org.jgroups.protocols.rules
org.jgroups.protocols.tom
org.jgroups.stack	Support for managing protocol stacks.
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Classes in org.jgroups.util used by org.jgroups

Class and Description
Buffer Buffer with an offset and length.
ByteArrayDataInputStream Implements DataInput over a byte[] buffer.
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
Promise Allows a thread to submit an asynchronous request and to wait for the result.
SocketFactory Factory to create various types of sockets.
StateTransferResult Encapsulates the result of a state transfer.
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
TimeScheduler Timer-like interface which allows for execution of tasks.

Classes in org.jgroups.util used by org.jgroups.auth

Class and Description
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization

Classes in org.jgroups.util used by org.jgroups.blocks

Class and Description
Buffer Buffer with an offset and length.
Condition
CondVar A condition variable with methods for (timed) waiting and signalling
FutureListener A listener that is called back when a future is done.
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
NotifyingFuture A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the future completes.
RpcStats Keeps track of stats for sync and async unicasts and multicasts
Rsp Class that represents a response from a communication
RspList Contains responses from all members.
SocketFactory Factory to create various types of sockets.
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
ThreadFactory

Classes in org.jgroups.util used by org.jgroups.blocks.cs

Class and Description
Buffer Buffer with an offset and length.
Condition
CondVar A condition variable with methods for (timed) waiting and signalling
SocketFactory Factory to create various types of sockets.
ThreadFactory
TimeService Provides a coarse grained time service.

Classes in org.jgroups.util used by org.jgroups.blocks.executor

Class and Description
FutureListener A listener that is called back when a future is done.
NotifyingFuture A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the future completes.
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization

Classes in org.jgroups.util used by org.jgroups.blocks.locking

Class and Description
Owner Represents an 'owner', which is an address and thread ID

Classes in org.jgroups.util used by org.jgroups.blocks.mux

Class and Description
FutureListener A listener that is called back when a future is done.
ImmutableReference Simple class that holds an immutable reference to another object (or to null).
RspList Contains responses from all members.
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization

Classes in org.jgroups.util used by org.jgroups.conf

Class and Description
Triple Holds 3 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.

Classes in org.jgroups.util used by org.jgroups.demos

Class and Description
Owner Represents an 'owner', which is an address and thread ID
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization

Classes in org.jgroups.util used by org.jgroups.fork

Class and Description
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).

Classes in org.jgroups.util used by org.jgroups.protocols

Class and Description
AckCollector Collects acks from a number of nodes, waits for all acks.
AgeOutCache Cache which removes its elements after a certain time
AgeOutCache.Handler
AsciiString Simple string implemented as a byte[] array.
Average Maintains an approximation of an average of values.
AverageMinMax Measures min and max in addition to average
BiConsumer Required by RingBuffer.
BoundedHashMap Bounded linked hashmap; used by SEQUENCER (and probably soon) FORWARD_TO_COORD
BoundedList A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
Buffer Buffer with an offset and length.
ByteArrayDataOutputStream Implements DataOutput over a byte[] buffer.
Condition
CondVar A condition variable with methods for (timed) waiting and signalling
CreditMap Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.
ExpiryCache Cache which maintains timestamps for keys, and methods to remove/replace expired keys.
Filter
ForwardQueue Forwards messages in FIFO order to a destination.
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
MessageBatch.Visitor Used for iteration over the messages
Owner Represents an 'owner', which is an address and thread ID
Promise Allows a thread to submit an asynchronous request and to wait for the result.
ResponseCollector Similar to AckCollector, but collects responses from cluster members, not just acks.
ResponseCollectorTask Task which is seeded with an initial membership.
Responses Manages responses for the discovery protocol.
RingBuffer Ring buffer of fixed capacity designed for multiple writers but only a single reader.
Runner Runs a given function in a loop (in a separate thread) until it is stopped
SeqnoList A bitset of missing messages with a fixed size.
SingletonAddress Address with a cluster name.
SizeStreamable Interface implementing Streamable and returning the size of the marshalled object.
SocketFactory Factory to create various types of sockets.
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
SuppressLog Log (using SuppressCache) which suppresses (certain) messages from the same member for a given time
Table A store for elements (typically messages) to be retransmitted or delivered.
ThreadFactory
TimeScheduler Timer-like interface which allows for execution of tasks.
TimeScheduler.Task The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implement
TimeService Provides a coarse grained time service.
Tuple Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
UUID Logical address which is unique over space and time.

Classes in org.jgroups.util used by org.jgroups.protocols.pbcast

Class and Description
AckCollector Collects acks from a number of nodes, waits for all acks.
AsciiString Simple string implemented as a byte[] array.
BlockingInputStream Bounded input stream.
BoundedList A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
Buffer Buffer with an offset and length.
Digest A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).
Filter
FixedSizeBitSet Class copied from BitSet.
MergeId ID to uniquely identify a merge
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
MutableDigest A mutable version of Digest.
ProcessingQueue A queue with many producers and consumers.
ProcessingQueue.Handler
Promise Allows a thread to submit an asynchronous request and to wait for the result.
Range
ResponseCollector Similar to AckCollector, but collects responses from cluster members, not just acks.
Responses Manages responses for the discovery protocol.
SeqnoList A bitset of missing messages with a fixed size.
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
SuppressLog Log (using SuppressCache) which suppresses (certain) messages from the same member for a given time
Table A store for elements (typically messages) to be retransmitted or delivered.
Table.Visitor
TimeScheduler Timer-like interface which allows for execution of tasks.
TimeScheduler.Task The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implement
Tuple Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.

Classes in org.jgroups.util used by org.jgroups.protocols.relay

Class and Description
ExtendedUUID Subclass of UUID accommodating additional data such as a flag and a small hashmap.
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
TimeScheduler Timer-like interface which allows for execution of tasks.
TopologyUUID Deprecated. Use ExtendedUUID instead. This class will be dropped in 4.0.
UUID Logical address which is unique over space and time.

Classes in org.jgroups.util used by org.jgroups.protocols.rules

Class and Description
BoundedList A bounded subclass of LinkedList, oldest elements are removed once max capacity is exceeded.
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
TimeScheduler Timer-like interface which allows for execution of tasks.
Tuple Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.

Classes in org.jgroups.util used by org.jgroups.protocols.tom

Class and Description
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization

Classes in org.jgroups.util used by org.jgroups.stack

Class and Description
ByteArrayDataInputStream Implements DataInput over a byte[] buffer.
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
Seqno Keeps track of a single message to retransmit
SizeStreamable Interface implementing Streamable and returning the size of the marshalled object.
SocketFactory Factory to create various types of sockets.
StackType
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
ThreadFactory
TimeScheduler Timer-like interface which allows for execution of tasks.
TimeScheduler.Task The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implement
Tuple Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.

Classes in org.jgroups.util used by org.jgroups.util

Class and Description
AdditionalDataUUID Deprecated. Use ExtendedUUID instead. Will get dropped in 4.0.
AgeOutCache.Handler
AsciiString Simple string implemented as a byte[] array.
Average Maintains an approximation of an average of values.
AverageMinMax Measures min and max in addition to average
BiConsumer Required by RingBuffer.
BoundedHashMap Bounded linked hashmap; used by SEQUENCER (and probably soon) FORWARD_TO_COORD
Buffer Buffer with an offset and length.
ByteArrayDataInputStream Implements DataInput over a byte[] buffer.
ByteArrayDataOutputStream Implements DataOutput over a byte[] buffer.
Condition
CondVar A condition variable with methods for (timed) waiting and signalling
DefaultThreadFactory Thread factory mainly responsible for naming of threads.
Digest A message digest containing - for each member - the highest seqno delivered (hd) and the highest seqno received (hr).
Digest.Entry Keeps track of one members plus its highest delivered and received seqnos
ExtendedUUID Subclass of UUID accommodating additional data such as a flag and a small hashmap.
Filter
FixedSizeBitSet Class copied from BitSet.
ForwardQueue.Flusher
FutureListener A listener that is called back when a future is done.
HashedTimingWheel.MyTask Simple task wrapper, always executed by at most 1 thread.
MergeId ID to uniquely identify a merge
MessageBatch Represents a message batch; multiple messages from the same sender to the same receiver(s).
MessageBatch.Mode
MessageBatch.Visitor Used for iteration over the messages
MutableDigest A mutable version of Digest.
MyReceiver Generic receiver for a JChannel
NotifyingFuture A sub-interface of a Future, that allows for listeners to be attached so that observers can be notified when the future completes.
Owner Represents an 'owner', which is an address and thread ID
PayloadUUID Deprecated. Use ExtendedUUID instead. Will get dropped in 4.0.
Pool.Creator
Pool.Element
ProcessingQueue A queue with many producers and consumers.
ProcessingQueue.Handler
Promise Allows a thread to submit an asynchronous request and to wait for the result.
Queue Elements are added at the tail and removed from the head.
QueueClosedException
Range
RequestTable Table for storing requests associated with monotonically increasing sequence numbers (seqnos). Used for example in RequestCorrelator.
RequestTable.Visitor
ResponseCollector Similar to AckCollector, but collects responses from cluster members, not just acks.
ResponseCollectorTask Task which is seeded with an initial membership.
ResponseCollectorTask.Consumer
Responses Manages responses for the discovery protocol.
RingBuffer Ring buffer of fixed capacity designed for multiple writers but only a single reader.
RpcStats Keeps track of stats for sync and async unicasts and multicasts
RpcStats.Result
RpcStats.Type
Rsp Class that represents a response from a communication
Seqno Keeps track of a single message to retransmit
SeqnoList A bitset of missing messages with a fixed size.
SocketFactory Factory to create various types of sockets.
StackType
Streamable Implementations of Streamable can add their state directly to the output stream, enabling them to bypass costly serialization
SuppressCache Cache which keeps a timestamp and counter for every key.
SuppressCache.Value
SuppressLog.Level
Table.Visitor
ThreadFactory
TimeScheduler Timer-like interface which allows for execution of tasks.
TimeScheduler.Task The interface that dynamic tasks (TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implement
TimeScheduler2.MyTask Deprecated. Simple task wrapper, always executed by at most 1 thread.
TimeScheduler3.Task
TimeScheduler3.TaskType
TimeService Provides a coarse grained time service.
TopologyUUID Deprecated. Use ExtendedUUID instead. This class will be dropped in 4.0.
Tuple Holds 2 values, useful when we have a map with a key, but more than 1 value and we don't want to create a separate holder object for the values, and don't want to pass the values as a list or array.
Util.AddressScope
UUID Logical address which is unique over space and time.