|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ThreadFactory | |
---|---|
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. |
Uses of ThreadFactory in org.jgroups.blocks |
---|
Fields in org.jgroups.blocks declared as ThreadFactory | |
---|---|
protected ThreadFactory |
AbstractConnectionMap.factory
|
Methods in org.jgroups.blocks that return ThreadFactory | |
---|---|
ThreadFactory |
BasicConnectionTable.getThreadFactory()
|
ThreadFactory |
AbstractConnectionMap.getThreadFactory()
|
Methods in org.jgroups.blocks with parameters of type ThreadFactory | |
---|---|
void |
BasicConnectionTable.setThreadFactory(ThreadFactory factory)
|
protected void |
TCPConnectionMap.TCPConnection.start(ThreadFactory f)
|
Constructors in org.jgroups.blocks with parameters of type ThreadFactory | |
---|---|
AbstractConnectionMap(ThreadFactory factory)
|
|
AbstractConnectionMap(ThreadFactory factory,
long reaperInterval)
|
|
TCPConnectionMap.Mapper(ThreadFactory factory)
|
|
TCPConnectionMap.Mapper(ThreadFactory factory,
long reaper_interval)
|
|
TCPConnectionMap.TCPConnection.ConnectionPeerReceiver(ThreadFactory f)
|
|
TCPConnectionMap.TCPConnection.Sender(ThreadFactory tf,
int send_queue_size)
|
|
TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int external_port,
int srv_port,
int max_port)
|
|
TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
SocketFactory socket_factory,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int external_port,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time)
|
|
TCPConnectionMap(java.lang.String service_name,
ThreadFactory f,
TCPConnectionMap.Receiver r,
java.net.InetAddress bind_addr,
java.net.InetAddress external_addr,
int external_port,
int srv_port,
int max_port,
long reaper_interval,
long conn_expire_time)
|
Uses of ThreadFactory in org.jgroups.protocols |
---|
Fields in org.jgroups.protocols declared as ThreadFactory | |
---|---|
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.oob_thread_factory
Factory which is used by oob_thread_pool |
protected ThreadFactory |
SCOPE.thread_factory
|
protected ThreadFactory |
TP.timer_thread_factory
|
Methods in org.jgroups.protocols that return ThreadFactory | |
---|---|
ThreadFactory |
TP.getDefaultThreadPoolThreadFactory()
|
ThreadFactory |
TP.getOOBThreadPoolThreadFactory()
|
ThreadFactory |
TP.getThreadFactory()
|
ThreadFactory |
TP.ProtocolAdapter.getThreadFactory()
|
ThreadFactory |
TP.getTimerThreadFactory()
|
Methods in org.jgroups.protocols with parameters of type ThreadFactory | |
---|---|
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)
|
void |
TP.setDefaultThreadPoolThreadFactory(ThreadFactory factory)
|
void |
TP.setOOBThreadPoolThreadFactory(ThreadFactory factory)
|
void |
TP.setThreadFactory(ThreadFactory factory)
|
void |
TP.setTimerThreadFactory(ThreadFactory factory)
|
Uses of ThreadFactory in org.jgroups.stack |
---|
Fields in org.jgroups.stack declared as ThreadFactory | |
---|---|
protected ThreadFactory |
GossipRouter.default_thread_factory
|
protected ThreadFactory |
DiagnosticsHandler.thread_factory
|
Methods in org.jgroups.stack that return ThreadFactory | |
---|---|
ThreadFactory |
GossipRouter.getDefaultThreadPoolThreadFactory()
|
ThreadFactory |
Protocol.getThreadFactory()
Supposed to be overwritten by subclasses. |
Constructors in org.jgroups.stack with parameters of type ThreadFactory | |
---|---|
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)
|
Uses of ThreadFactory in org.jgroups.util |
---|
Fields in org.jgroups.util declared as ThreadFactory | |
---|---|
protected ThreadFactory |
TimeScheduler3.timer_thread_factory
|
protected ThreadFactory |
HashedTimingWheel.timer_thread_factory
|
protected ThreadFactory |
TimeScheduler2.timer_thread_factory
|
Methods in org.jgroups.util with parameters of type ThreadFactory | |
---|---|
static void |
Util.runAsync(java.lang.Runnable task,
ThreadFactory factory,
java.lang.String thread_name)
Runs a task on a separate thread |
void |
TimeScheduler.setThreadFactory(ThreadFactory factory)
|
void |
MockTimeScheduler.setThreadFactory(ThreadFactory factory)
|
void |
TimeScheduler3.setThreadFactory(ThreadFactory f)
|
void |
DefaultTimeScheduler.setThreadFactory(ThreadFactory factory)
|
void |
HashedTimingWheel.setThreadFactory(ThreadFactory factory)
|
void |
TimeScheduler2.setThreadFactory(ThreadFactory f)
|
Constructors in org.jgroups.util with parameters of type ThreadFactory | |
---|---|
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)
|
|
TimeScheduler2(ThreadFactory factory,
int min_threads,
int max_threads,
long keep_alive_time,
int max_queue_size,
java.lang.String rejection_policy)
|
|
TimeScheduler3(ThreadFactory factory,
int min_threads,
int max_threads,
long keep_alive_time,
int max_queue_size,
java.lang.String rejection_policy)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |