Class DefaultThreadFactory

src/org/jgroups/util/DefaultThreadFactory.java:19–129

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,MyCl

 * @author Bela Ban
 */
public class DefaultThreadFactory implements ThreadFactory {
    protected final String        baseName;
    protected final boolean       createDaemons;
    protected final boolean       use_numbering;
    protected final AtomicInteger counter=new AtomicInteger(); // if numbering is enabled
    protected boolean             includeClusterName;
    protected String              clusterName;
    protected boolean             includeLocalAddress;
    protected String              address;
    protected boolean             use_vthreads; // use fibers instead of threads (requires Java 15)
    protected Log                 log;


    public DefaultThreadFactory(String base_name, boolean createDaemons) {
        this(base_name, createDaemons, false);
    }

    public DefaultThreadFactory(String base_name, boolean createDaemons, boolean use_numbering) {
        this.baseName=base_name;
        this.createDaemons=createDaemons;
        this.use_numbering=use_numbering;
    }

    public void setPattern(String pattern) {
        if(pattern != null) {
            includeClusterName=pattern.contains("c");
            includeLocalAddress=pattern.contains("l");
        }
    }

    public void setIncludeClusterName(boolean includeClusterName) {
        this.includeClusterName=includeClusterName;
    }

    public void setClusterName(String channelName) {
        clusterName=channelName;
    }

    public void setAddress(String address) {
        this.address=address;
    }

    @Deprecated(forRemoval=true)
    public boolean                            useFibers()                  {return useVirtualThreads();}
    @Deprecated(forRemoval=true)
    public <T extends DefaultThreadFactory> T useFibers(boolean f)         {return useVirtualThreads(f);}
    @Override
    public boolean                            useVirtualThreads()          {return use_vthreads;}
    public <T extends DefaultThreadFactory> T useVirtualThreads(boolean f) {this.use_vthreads=f; return (T)this;}
    public <T extends DefaultThreadFactory> T useVThreads(boolean f)       {return useVirtualThreads(f);}
    public <T extends DefaultThreadFactory> T log(Log l)                   {this.log=l; return (T)this;}

    public Thread newThread(Runnable r, String name) {
        return newThread(r, name, null, null);
    }

    public Thread newThread(Runnable r) {
        return newThread(r, baseName, null, null);