Package | Description |
---|---|
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.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 and Description |
---|---|
ThreadFactory |
BasicConnectionTable.getThreadFactory() |
Modifier and Type | Method and Description |
---|---|
void |
BasicConnectionTable.setThreadFactory(ThreadFactory factory) |
Modifier and Type | Field and Description |
---|---|
protected ThreadFactory |
BaseServer.factory |
Constructor and Description |
---|
BaseServer(ThreadFactory f) |
NioBaseServer(ThreadFactory f) |
NioClient(ThreadFactory thread_factory) |
NioServer(ThreadFactory f) |
NioServer(ThreadFactory thread_factory,
java.net.InetAddress bind_addr,
int srv_port,
int end_port,
java.net.InetAddress external_addr,
int external_port)
Creates an instance of
NioServer that opens a server channel and listens for connections. |
Receiver(ThreadFactory f) |
Sender(ThreadFactory tf,
int send_queue_size) |
TcpBaseServer(ThreadFactory f) |
TcpClient(ThreadFactory thread_factory,
SocketFactory socket_factory) |
TcpServer(ThreadFactory thread_factory,
SocketFactory socket_factory) |
TcpServer(ThreadFactory thread_factory,
SocketFactory socket_factory,
java.net.InetAddress bind_addr,
int srv_port,
int end_port,
java.net.InetAddress external_addr,
int external_port)
Creates an instance of
TcpServer that creates a server socket and listens for connections
Needs to be started next. |
Modifier and Type | Field and Description |
---|---|
protected ThreadFactory |
TP.default_thread_factory
Factory which is used by oob_thread_pool
|
protected ThreadFactory |
TP.global_thread_factory
Used by all threads created by JGroups outside of the thread pools
|
protected ThreadFactory |
TP.internal_thread_factory
Factory which is used by internal_thread_pool
|
protected ThreadFactory |
TP.oob_thread_factory
Factory which is used by oob_thread_pool
|
protected ThreadFactory |
SCOPE.thread_factory
Deprecated.
|
protected ThreadFactory |
TP.timer_thread_factory |
Modifier and Type | Method and Description |
---|---|
ThreadFactory |
TP.getDefaultThreadPoolThreadFactory() |
ThreadFactory |
TP.getInternalThreadPoolThreadFactory() |
ThreadFactory |
TP.getOOBThreadPoolThreadFactory() |
ThreadFactory |
TP.getThreadFactory() |
ThreadFactory |
TP.ProtocolAdapter.getThreadFactory() |
ThreadFactory |
TP.getTimerThreadFactory() |
Modifier and Type | Method and 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) |
protected static java.util.concurrent.ExecutorService |
SCOPE.createThreadPool(int min_threads,
int max_threads,
long keep_alive_time,
ThreadFactory factory)
Deprecated.
|
void |
TP.setDefaultThreadPoolThreadFactory(ThreadFactory factory) |
void |
TP.setInternalThreadPoolThreadFactory(ThreadFactory factory) |
void |
TP.setOOBThreadPoolThreadFactory(ThreadFactory factory) |
void |
TP.setThreadFactory(ThreadFactory factory) |
void |
TP.setTimerThreadFactory(ThreadFactory factory) |
Modifier and Type | Field and Description |
---|---|
protected ThreadFactory |
GossipRouter.thread_factory |
protected ThreadFactory |
DiagnosticsHandler.thread_factory |
Modifier and Type | Method and Description |
---|---|
ThreadFactory |
Protocol.getThreadFactory()
Supposed to be overwritten by subclasses.
|
ThreadFactory |
GossipRouter.threadPoolFactory() |
Modifier and Type | Method and Description |
---|---|
GossipRouter |
GossipRouter.threadPoolFactory(ThreadFactory f) |
Constructor and Description |
---|
DiagnosticsHandler(java.net.InetAddress diagnostics_addr,
int diagnostics_port,
java.util.List<java.net.NetworkInterface> bind_interfaces,
int diagnostics_ttl,
Log log,
SocketFactory socket_factory,
ThreadFactory thread_factory,
java.lang.String passcode) |
DiagnosticsHandler(java.net.InetAddress diagnostics_addr,
int diagnostics_port,
Log log,
SocketFactory socket_factory,
ThreadFactory thread_factory) |
DiagnosticsHandler(java.net.InetAddress diagnostics_addr,
int diagnostics_port,
Log log,
SocketFactory socket_factory,
ThreadFactory thread_factory,
java.lang.String passcode) |
Modifier and Type | Field and Description |
---|---|
protected ThreadFactory |
Runner.factory |
protected ThreadFactory |
HashedTimingWheel.timer_thread_factory |
protected ThreadFactory |
TimeScheduler2.timer_thread_factory
Deprecated.
|
protected ThreadFactory |
TimeScheduler3.timer_thread_factory |
Modifier and Type | Method and Description |
---|---|
void |
HashedTimingWheel.setThreadFactory(ThreadFactory factory) |
void |
TimeScheduler2.setThreadFactory(ThreadFactory f)
Deprecated.
|
void |
DefaultTimeScheduler.setThreadFactory(ThreadFactory factory) |
void |
TimeScheduler3.setThreadFactory(ThreadFactory f) |
void |
MockTimeScheduler.setThreadFactory(ThreadFactory factory) |
void |
TimeScheduler.setThreadFactory(ThreadFactory factory) |
Constructor and Description |
---|
DefaultTimeScheduler(ThreadFactory factory) |
DefaultTimeScheduler(ThreadFactory factory,
int max_threads) |
HashedTimingWheel(ThreadFactory factory,
int min_threads,
int max_threads,
long keep_alive_time,
int max_queue_size,
int wheel_size,
long tick_time) |
Runner(ThreadFactory factory,
java.lang.String thread_name,
java.lang.Runnable function,
java.lang.Runnable stop_function) |
TimeScheduler2(ThreadFactory factory,
int min_threads,
int max_threads,
long keep_alive_time,
int max_queue_size,
java.lang.String rejection_policy)
Deprecated.
|
TimeScheduler3(ThreadFactory factory,
int min_threads,
int max_threads,
long keep_alive_time,
int max_queue_size,
java.lang.String rejection_policy) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.