Uses of Interface
org.jgroups.util.ThreadFactory
Packages that use ThreadFactory
Package
Description
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
Support for managing protocol stacks.
Provides useful functionality which cannot be assigned to any particular other package.
-
Uses of ThreadFactory in org.jgroups.blocks.cs
Fields in org.jgroups.blocks.cs declared as ThreadFactoryConstructors in org.jgroups.blocks.cs with parameters of type ThreadFactoryModifierConstructorDescriptionprotectedBaseServer(ThreadFactory f, SocketFactory sf, int recv_buf_size) protectedNioBaseServer(ThreadFactory f, SocketFactory sf, int recv_buf_size) NioServer(ThreadFactory thread_factory, SocketFactory socket_factory, InetAddress bind_addr, int srv_port, int end_port, InetAddress external_addr, int external_port, int recv_buf_size) NioServer(ThreadFactory thread_factory, SocketFactory socket_factory, InetAddress bind_addr, int srv_port, int end_port, InetAddress external_addr, int external_port, int recv_buf_size, String service_name) Creates an instance ofNioServerthat opens a server channel and listens for connections.protectedTcpBaseServer(ThreadFactory f, SocketFactory sf, int recv_buf_size) TcpServer(ThreadFactory thread_factory, SocketFactory socket_factory, InetAddress bind_addr, int srv_port, int end_port, InetAddress external_addr, int external_port, int recv_buf_size) TcpServer(ThreadFactory thread_factory, SocketFactory socket_factory, InetAddress bind_addr, int srv_port, int end_port, InetAddress external_addr, int external_port, int recv_buf_size, String service_name) Creates an instance ofTcpServerthat creates a server socket and listens for connections Needs to be started next. -
Uses of ThreadFactory in org.jgroups.protocols
Fields in org.jgroups.protocols declared as ThreadFactoryMethods in org.jgroups.protocols that return ThreadFactoryMethods in org.jgroups.protocols with parameters of type ThreadFactoryModifier and TypeMethodDescription<T extends TP>
TTPConfig.setThreadFactory(ThreadFactory factory) -
Uses of ThreadFactory in org.jgroups.stack
Fields in org.jgroups.stack declared as ThreadFactoryModifier and TypeFieldDescriptionprotected final ThreadFactoryDiagnosticsHandler.thread_factoryprotected ThreadFactoryGossipRouter.thread_factoryMethods in org.jgroups.stack that return ThreadFactoryModifier and TypeMethodDescriptionProtocol.getThreadFactory()Supposed to be overwritten by subclasses.GossipRouter.threadPoolFactory()Methods in org.jgroups.stack with parameters of type ThreadFactoryConstructors in org.jgroups.stack with parameters of type ThreadFactoryModifierConstructorDescriptionDiagnosticsHandler(Log log, SocketFactory socket_factory, ThreadFactory thread_factory) -
Uses of ThreadFactory in org.jgroups.util
Classes in org.jgroups.util that implement ThreadFactoryModifier and TypeClassDescriptionclassThread factory mainly responsible for naming of threads.classLazily names threads: whenever the address or cluster name is changed, all threads are renamedFields in org.jgroups.util declared as ThreadFactoryModifier and TypeFieldDescriptionprotected final ThreadFactoryRunner.factoryprotected ThreadFactoryThreadPool.thread_factoryprotected ThreadFactoryTimeScheduler3.timer_thread_factoryMethods in org.jgroups.util that return ThreadFactoryMethods in org.jgroups.util with parameters of type ThreadFactoryModifier and TypeMethodDescriptionprotected static ExecutorServiceThreadPool.createThreadPool(int min_threads, int max_threads, long keep_alive_time, String rejection_policy, BlockingQueue<Runnable> queue, ThreadFactory factory, Log log) protected static ExecutorServiceThreadPool.newVirtualThreadPool(ThreadFactory factory) ThreadPool.setThreadFactory(ThreadFactory factory) voidTimeScheduler.setThreadFactory(ThreadFactory factory) voidTimeScheduler3.setThreadFactory(ThreadFactory f) Constructors in org.jgroups.util with parameters of type ThreadFactoryModifierConstructorDescriptionRunner(ThreadFactory factory, String thread_name, Runnable function, Runnable stop_function) TimeScheduler3(ThreadFactory factory, int min_threads, int max_threads, long keep_alive_time, int max_queue_size, String rejection_policy) TimeScheduler3(ThreadFactory factory, int min_threads, int max_threads, long keep_alive_time, BlockingQueue<Runnable> queue, String rejection_policy, boolean thread_pool_enabled) TimeScheduler3(ThreadPool thread_pool, ThreadFactory factory, boolean start)