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.

Author:

Vladimir Blagojevic, Bela Ban

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected String	getThreadName(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	setAddress(String address)
void	setClusterName(String channelName)
void	setIncludeClusterName(boolean includeClusterName)
void	setIncludeLocalAddress(boolean f)
void	setPattern(String pattern)
void	setUseNumbering(boolean f)
boolean	useVirtualThreads()
<T extends DefaultThreadFactory> T	useVirtualThreads(boolean f)
<T extends DefaultThreadFactory> T	useVThreads(boolean f)

Methods inherited from class 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 boolean use_numbering

counter

protected final AtomicInteger counter

includeClusterName

protected boolean includeClusterName

clusterName

protected String clusterName

includeLocalAddress

protected boolean includeLocalAddress

address

protected String address

use_vthreads

protected boolean use_vthreads

log

protected Log log

Constructor Details

DefaultThreadFactory

public DefaultThreadFactory(String base_name,
 boolean createDaemons)

DefaultThreadFactory

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

Method Details

setPattern

public void setPattern(String pattern)

Specified by:

setPattern in interface ThreadFactory

setUseNumbering

public void setUseNumbering(boolean f)

setIncludeClusterName

public void setIncludeClusterName(boolean includeClusterName)

Specified by:

setIncludeClusterName in interface ThreadFactory

setIncludeLocalAddress

public void setIncludeLocalAddress(boolean f)

setClusterName

public void setClusterName(String channelName)

Specified by:

setClusterName in interface ThreadFactory

setAddress

public void setAddress(String address)

Specified by:

setAddress in interface ThreadFactory

useVirtualThreads

public boolean useVirtualThreads()

Specified by:

useVirtualThreads in interface ThreadFactory

useVirtualThreads

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

useVThreads

public <T extends DefaultThreadFactory> T useVThreads(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.

getThreadName

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

getThreadName

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