Package org.jgroups.util
Class LazyThreadFactory
- java.lang.Object
-
- org.jgroups.util.DefaultThreadFactory
-
- org.jgroups.util.LazyThreadFactory
-
- All Implemented Interfaces:
java.util.concurrent.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 org.jgroups.util.DefaultThreadFactory
address, baseName, clusterName, counter, createDaemons, includeClusterName, includeLocalAddress, log, use_fibers, use_numbering
-
-
Constructor Summary
Constructors Constructor Description LazyThreadFactory(java.lang.String baseName, boolean createDaemons, boolean use_numbering)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.lang.StringchangeName(java.lang.String name)Replaces "" with the local address and with the cluster name voiddestroy()java.lang.StringdumpThreads()java.lang.ThreadnewThread(java.lang.Runnable r)java.lang.ThreadnewThread(java.lang.Runnable r, java.lang.String name)voidremoveTerminatedThreads()protected voidrenameThreads()voidsetAddress(java.lang.String address)voidsetClusterName(java.lang.String cluster_name)intsize()-
Methods inherited from class org.jgroups.util.DefaultThreadFactory
getNewThreadName, getThreadName, log, newThread, renameThread, renameThread, renameThread, setIncludeClusterName, setPattern, useFibers, useFibers
-
-
-
-
Method Detail
-
newThread
public java.lang.Thread newThread(java.lang.Runnable r)
- Specified by:
newThreadin interfacejava.util.concurrent.ThreadFactory- Overrides:
newThreadin classDefaultThreadFactory
-
newThread
public java.lang.Thread newThread(java.lang.Runnable r, java.lang.String name)- Specified by:
newThreadin interfaceThreadFactory- Overrides:
newThreadin classDefaultThreadFactory
-
setAddress
public void setAddress(java.lang.String address)
- Specified by:
setAddressin interfaceThreadFactory- Overrides:
setAddressin classDefaultThreadFactory
-
setClusterName
public void setClusterName(java.lang.String cluster_name)
- Specified by:
setClusterNamein interfaceThreadFactory- Overrides:
setClusterNamein classDefaultThreadFactory
-
size
public int size()
-
destroy
public void destroy()
-
removeTerminatedThreads
public void removeTerminatedThreads()
-
dumpThreads
public java.lang.String dumpThreads()
-
renameThreads
protected void renameThreads()
-
changeName
protected java.lang.String changeName(java.lang.String name)
Replaces "" with the local address and with the cluster name
-
-