Package | Description |
---|---|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected static BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.PARK |
protected static BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.SPIN |
protected static BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.SPIN_PARK |
protected static BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.SPIN_YIELD |
protected BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.wait_strategy |
protected static BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.YIELD |
Modifier and Type | Method and Description |
---|---|
protected BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.createWaitStrategy(java.lang.String st,
BiConsumer<java.lang.Integer,java.lang.Integer> default_wait_strategy) |
Modifier and Type | Method and Description |
---|---|
protected BiConsumer<java.lang.Integer,java.lang.Integer> |
RingBufferBundler.createWaitStrategy(java.lang.String st,
BiConsumer<java.lang.Integer,java.lang.Integer> default_wait_strategy) |
protected static java.lang.String |
RingBufferBundler.print(BiConsumer<java.lang.Integer,java.lang.Integer> wait_strategy) |
Modifier and Type | Method and Description |
---|---|
int |
RingBuffer.waitForMessages(int num_spins,
BiConsumer<java.lang.Integer,java.lang.Integer> wait_strategy)
Blocks until messages are available
|
Copyright © 1998-2020 Red Hat. All Rights Reserved.