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<Integer,Integer> |
RingBufferBundler.PARK |
protected static BiConsumer<Integer,Integer> |
RingBufferBundler.SPIN |
protected static BiConsumer<Integer,Integer> |
RingBufferBundler.SPIN_PARK |
protected static BiConsumer<Integer,Integer> |
RingBufferBundler.SPIN_YIELD |
protected BiConsumer<Integer,Integer> |
RingBufferBundler.wait_strategy |
protected static BiConsumer<Integer,Integer> |
RingBufferBundler.YIELD |
Modifier and Type | Method and Description |
---|---|
protected BiConsumer<Integer,Integer> |
RingBufferBundler.createWaitStrategy(String st,
BiConsumer<Integer,Integer> default_wait_strategy) |
Modifier and Type | Method and Description |
---|---|
protected BiConsumer<Integer,Integer> |
RingBufferBundler.createWaitStrategy(String st,
BiConsumer<Integer,Integer> default_wait_strategy) |
protected static String |
RingBufferBundler.print(BiConsumer<Integer,Integer> wait_strategy) |
Modifier and Type | Method and Description |
---|---|
int |
RingBuffer.waitForMessages(int num_spins,
BiConsumer<Integer,Integer> wait_strategy)
Blocks until messages are available
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.