接口 com.fr.third.jgroups.util.ThreadFactory
的使用

使用ThreadFactory的程序包

程序包	说明
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.protocols	Provides implementations of transport protocols which are responsible for sending and receiving messages to/from the network.
com.fr.third.jgroups.stack	Support for managing protocol stacks.
com.fr.third.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

com.fr.third.jgroups.blocks中ThreadFactory的使用

声明为ThreadFactory的com.fr.third.jgroups.blocks中的字段

限定符和类型	字段和说明
protected ThreadFactory	AbstractConnectionMap.factory

返回ThreadFactory的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
ThreadFactory	BasicConnectionTable.getThreadFactory()
ThreadFactory	AbstractConnectionMap.getThreadFactory()

参数类型为ThreadFactory的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
void	BasicConnectionTable.setThreadFactory(ThreadFactory factory)
protected TCPConnectionMap.TCPConnection	TCPConnectionMap.TCPConnection.start(ThreadFactory f)

参数类型为ThreadFactory的com.fr.third.jgroups.blocks中的构造器

构造器和说明
AbstractConnectionMap(ThreadFactory factory)
AbstractConnectionMap(ThreadFactory factory, long reaperInterval)
TCPConnectionMap.Mapper(ThreadFactory factory)
TCPConnectionMap.Mapper(ThreadFactory factory, long reaper_interval)
TCPConnectionMap.TCPConnection.Receiver(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)

com.fr.third.jgroups.protocols中ThreadFactory的使用

声明为ThreadFactory的com.fr.third.jgroups.protocols中的字段

限定符和类型	字段和说明
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 已过时。
protected ThreadFactory	TP.timer_thread_factory

返回ThreadFactory的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
ThreadFactory	TP.getDefaultThreadPoolThreadFactory()
ThreadFactory	TP.getInternalThreadPoolThreadFactory()
ThreadFactory	TP.getOOBThreadPoolThreadFactory()
ThreadFactory	TP.getThreadFactory()
ThreadFactory	TP.ProtocolAdapter.getThreadFactory()
ThreadFactory	TP.getTimerThreadFactory()

参数类型为ThreadFactory的com.fr.third.jgroups.protocols中的方法

限定符和类型	方法和说明
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.setInternalThreadPoolThreadFactory(ThreadFactory factory)
void	TP.setOOBThreadPoolThreadFactory(ThreadFactory factory)
void	TP.setThreadFactory(ThreadFactory factory)
void	TP.setTimerThreadFactory(ThreadFactory factory)

com.fr.third.jgroups.stack中ThreadFactory的使用

声明为ThreadFactory的com.fr.third.jgroups.stack中的字段

限定符和类型	字段和说明
protected ThreadFactory	GossipRouter.default_thread_factory
protected ThreadFactory	DiagnosticsHandler.thread_factory

返回ThreadFactory的com.fr.third.jgroups.stack中的方法

限定符和类型	方法和说明
ThreadFactory	GossipRouter.getDefaultThreadPoolThreadFactory()
ThreadFactory	Protocol.getThreadFactory() Supposed to be overwritten by subclasses.

参数类型为ThreadFactory的com.fr.third.jgroups.stack中的构造器

构造器和说明
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)

com.fr.third.jgroups.util中ThreadFactory的使用

声明为ThreadFactory的com.fr.third.jgroups.util中的字段

限定符和类型	字段和说明
protected ThreadFactory	TimeScheduler3.timer_thread_factory
protected ThreadFactory	TimeScheduler2.timer_thread_factory
protected ThreadFactory	HashedTimingWheel.timer_thread_factory

参数类型为ThreadFactory的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
void	TimeScheduler3.setThreadFactory(ThreadFactory f)
void	TimeScheduler2.setThreadFactory(ThreadFactory f)
void	TimeScheduler.setThreadFactory(ThreadFactory factory)
void	MockTimeScheduler.setThreadFactory(ThreadFactory factory)
void	HashedTimingWheel.setThreadFactory(ThreadFactory factory)
void	DefaultTimeScheduler.setThreadFactory(ThreadFactory factory)

参数类型为ThreadFactory的com.fr.third.jgroups.util中的构造器

构造器和说明
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)