Package org.jgroups.util

Class DefaultThreadFactory

java.lang.Object

org.jgroups.util.DefaultThreadFactory

All Implemented Interfaces:

ThreadFactory, ThreadFactory

Direct Known Subclasses:

LazyThreadFactory

public class DefaultThreadFactory
extends Object
implements ThreadFactory

Thread factory mainly responsible for naming of threads. Can be replaced by user. If use_numbering is set, a thread THREAD will be called THREAD-1, THREAD-2, and so on.

If a pattern has been set (through setPattern()), then the cluster name and local address will also be added, e.g. THREAD-5,MyCluster,192.168.1.5:63754 or THREAD,MyCluster,192.168.1.5:63754

If includeClusterName and includeLocalAddress are both false, and clusterName is set, then we assume we have a shared transport, and therefore print shared=clusterName.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	address
protected final String	baseName
protected String	clusterName
protected short	counter
protected final boolean	createDaemons
protected boolean	includeClusterName
protected boolean	includeLocalAddress
protected Log	log
protected final boolean	use_numbering
protected boolean	use_virtual_threads

Constructor Summary

Constructors

Constructor	Description
DefaultThreadFactory(String baseName, boolean createDaemons)
DefaultThreadFactory(String baseName, boolean createDaemons, boolean use_numbering)

Method Summary

Modifier and Type	Method	Description
protected String	getNewThreadName(String base_name, String addr, String cluster_name)
protected String	getThreadName(String base_name, Thread thread, String addr, String cluster_name)
<T extends DefaultThreadFactory> T	log(Log l)
Thread	newThread(Runnable r)
Thread	newThread(Runnable r, String name)
protected Thread	newThread(Runnable r, String name, String addr, String cluster_name)
void	renameThread(String base_name, Thread thread)
void	renameThread(String base_name, Thread thread, String addr, String cluster_name)	Names a thread according to base_name, cluster name and local address.
void	renameThread(Thread thread)
void	setAddress(String address)
void	setClusterName(String channelName)
void	setIncludeClusterName(boolean includeClusterName)
void	setPattern(String pattern)
boolean	useFibers()	Deprecated, for removal: This API element is subject to removal in a future version.
<T extends DefaultThreadFactory> T	useFibers(boolean f)	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	useVirtualThreads()
<T extends DefaultThreadFactory> T	useVirtualThreads(boolean f)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

baseName

protected final String baseName

createDaemons

protected final boolean createDaemons

use_numbering

protected final boolean use_numbering

counter

protected short counter

includeClusterName

protected boolean includeClusterName

clusterName

protected String clusterName

includeLocalAddress

protected boolean includeLocalAddress

address

protected String address

use_virtual_threads

protected boolean use_virtual_threads

log

protected Log log

Constructor Details

DefaultThreadFactory

public DefaultThreadFactory(String baseName,
 boolean createDaemons)

DefaultThreadFactory

public DefaultThreadFactory(String baseName,
 boolean createDaemons,
 boolean use_numbering)

Method Details

setPattern

public void setPattern(String pattern)

Specified by:

setPattern in interface ThreadFactory

setIncludeClusterName

public void setIncludeClusterName(boolean includeClusterName)

Specified by:

setIncludeClusterName in interface ThreadFactory

setClusterName

public void setClusterName(String channelName)

Specified by:

setClusterName in interface ThreadFactory

setAddress

public void setAddress(String address)

Specified by:

setAddress in interface ThreadFactory

useFibers

@Deprecated(forRemoval=true)
public boolean useFibers()

Deprecated, for removal: This API element is subject to removal in a future version.

useFibers

@Deprecated(forRemoval=true)
public <T extends DefaultThreadFactory> T useFibers(boolean f)

Deprecated, for removal: This API element is subject to removal in a future version.

useVirtualThreads

public boolean useVirtualThreads()

useVirtualThreads

public <T extends DefaultThreadFactory> T useVirtualThreads(boolean f)

log

public <T extends DefaultThreadFactory> T log(Log l)

newThread

public Thread newThread(Runnable r,
 String name)

Specified by:

newThread in interface ThreadFactory

newThread

public Thread newThread(Runnable r)

Specified by:

newThread in interface ThreadFactory

newThread

protected Thread newThread(Runnable r,
 String name,
 String addr,
 String cluster_name)

renameThread

public void renameThread(String base_name,
 Thread thread)

Specified by:

renameThread in interface ThreadFactory

renameThread

public void renameThread(String base_name,
 Thread thread,
 String addr,
 String cluster_name)

Names a thread according to base_name, cluster name and local address. If includeClusterName and includeLocalAddress are null, but cluster_name is set, then we assume we have a shared transport and name the thread shared=clusterName. In the latter case, clusterName points to the singleton_name of TP.

Parameters:

base_name -

thread -

addr -

cluster_name -

renameThread

public void renameThread(Thread thread)

getThreadName

protected String getThreadName(String base_name,
 Thread thread,
 String addr,
 String cluster_name)

getNewThreadName

protected String getNewThreadName(String base_name,
 String addr,
 String cluster_name)