Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method | Description |
---|---|---|
ThreadFactory |
BasicConnectionTable.getThreadFactory() |
Modifier and Type | Method | Description |
---|---|---|
void |
BasicConnectionTable.setThreadFactory(ThreadFactory factory) |
Modifier and Type | Field | Description |
---|---|---|
protected ThreadFactory |
TP.global_thread_factory |
Used by all threads created by JGroups outside of the thread pools
|
protected ThreadFactory |
TP.timer_thread_factory |
Modifier and Type | Method | Description |
---|---|---|
ThreadFactory |
TP.getDefaultThreadPoolThreadFactory() |
|
ThreadFactory |
TP.getOOBThreadPoolThreadFactory() |
|
ThreadFactory |
TP.getThreadFactory() |
|
ThreadFactory |
TP.ProtocolAdapter.getThreadFactory() |
|
ThreadFactory |
TP.getTimerThreadFactory() |
Modifier and Type | Method | Description |
---|---|---|
protected static java.util.concurrent.ExecutorService |
TP.createThreadPool(int min_threads,
int max_threads,
long keep_alive_time,
java.lang.String rejection_policy,
java.util.concurrent.BlockingQueue<java.lang.Runnable> queue,
ThreadFactory factory) |
|
void |
TP.setDefaultThreadPoolThreadFactory(ThreadFactory factory) |
|
void |
TP.setOOBThreadPoolThreadFactory(ThreadFactory factory) |
|
void |
TP.setThreadFactory(ThreadFactory factory) |
|
void |
TP.setTimerThreadFactory(ThreadFactory factory) |
Modifier and Type | Field | Description |
---|---|---|
protected ThreadFactory |
GossipRouter.default_thread_factory |
Modifier and Type | Method | Description |
---|---|---|
ThreadFactory |
GossipRouter.getDefaultThreadPoolThreadFactory() |
|
ThreadFactory |
Protocol.getThreadFactory() |
Supposed to be overwritten by subclasses.
|
ThreadFactory |
ProtocolStack.getThreadFactory() |
Deprecated.
Use
Protocol.getThreadFactory() instead |
static ThreadFactory |
ProtocolStack.getTimerThreadFactory() |
Deprecated.
|
Modifier and Type | Method | Description |
---|---|---|
protected java.util.concurrent.ExecutorService |
GossipRouter.createThreadPool(int min_threads,
int max_threads,
long keep_alive_time,
java.lang.String rejection_policy,
java.util.concurrent.BlockingQueue<java.lang.Runnable> queue,
ThreadFactory factory) |
|
void |
GossipRouter.setDefaultThreadPoolThreadFactory(ThreadFactory factory) |
|
void |
ProtocolStack.setThreadFactory(ThreadFactory f) |
Deprecated.
Use
Protocol.getThreadFactory() instead |
static void |
ProtocolStack.setTimerThreadFactory(ThreadFactory f) |
Deprecated.
|
Modifier and Type | Class | Description |
---|---|---|
class |
DefaultThreadFactory |
Thread factory mainly responsible for naming of threads.
|
class |
LazyThreadFactory |
Lazily names threads: whenever the address or cluster name is changed, all threads are renamed
|
Constructor | Description |
---|---|
TimeScheduler(ThreadFactory factory) |
|
TimeScheduler(ThreadFactory factory,
int max_threads) |
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.