Class LazyThreadFactory

java.lang.Object

org.jgroups.util.DefaultThreadFactory

org.jgroups.util.LazyThreadFactory

All Implemented Interfaces:

ThreadFactory, ThreadFactory

public class LazyThreadFactory
extends DefaultThreadFactory

Lazily names threads: whenever the address or cluster name is changed, all threads are renamed

Author:

Bela Ban

Field Summary

Fields inherited from class DefaultThreadFactory

address, baseName, clusterName, counter, createDaemons, includeClusterName, includeLocalAddress, log, use_numbering, use_vthreads

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected String	changeName(String name)	Replaces "<ADDR>" with the local address and "<CLUSTER>" with the cluster name
void	destroy()
String	dumpThreads()
Thread	newThread(Runnable r)
Thread	newThread(Runnable r, String name)
void	removeTerminatedThreads()
void	renameThread(String base_name, Thread thread, String addr, String cluster_name)	Names a thread according to base_name, cluster name and local address.
protected void	renameThreads()
void	setAddress(String address)
void	setClusterName(String cluster_name)
int	size()

Methods inherited from class DefaultThreadFactory

getThreadName, getThreadName, log, newThread, renameThread, setIncludeClusterName, setIncludeLocalAddress, setPattern, setUseNumbering, useVirtualThreads, useVirtualThreads, useVThreads

Methods inherited from class Object

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

Constructor Details

LazyThreadFactory

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

Method Details

newThread

public Thread newThread(Runnable r)

Specified by:

newThread in interface ThreadFactory

Overrides:

newThread in class DefaultThreadFactory

newThread

public Thread newThread(Runnable r,
 String name)

Specified by:

newThread in interface ThreadFactory

Overrides:

newThread in class DefaultThreadFactory

renameThread

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

Description copied from class: DefaultThreadFactory

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.

Overrides:

renameThread in class DefaultThreadFactory

setAddress

public void setAddress(String address)

Specified by:

setAddress in interface ThreadFactory

Overrides:

setAddress in class DefaultThreadFactory

setClusterName

public void setClusterName(String cluster_name)

Specified by:

setClusterName in interface ThreadFactory

Overrides:

setClusterName in class DefaultThreadFactory

size

public int size()

destroy

public void destroy()

removeTerminatedThreads

public void removeTerminatedThreads()

dumpThreads

public String dumpThreads()

renameThreads

protected void renameThreads()

changeName

protected String changeName(String name)

Replaces "<ADDR>" with the local address and "<CLUSTER>" with the cluster name