【笔记】ThreadFactory自定义线程名前缀

前言

代码示例

自定义线程工厂 - NamedThreadFactory

package cn.mrxionge.idemo;

import org.jetbrains.annotations.NotNull;

import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * 带有前缀名称的线程工厂
 */
public class NamedThreadFactory implements ThreadFactory {
          
   

    /**
     * 线程名前缀
     */
    private final String prefix;

    /**
     * 线程编号
     */
    private final AtomicInteger threadNumber = new AtomicInteger(1);

    /**
     * 创建线程工厂
     *
     * @param prefix 线程名前缀
     */
    public NamedThreadFactory(String prefix) {
          
   
        this.prefix = prefix;
    }

    @Override
    public Thread newThread(@NotNull Runnable r) {
          
   
        return new Thread(null, r, prefix + threadNumber.getAndIncrement());
    }
}

测试方法（伪代码）

ThreadPoolExecutor executor = new ThreadPoolExecutor(50, 100, 5L, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100), new NamedThreadFactory("async-task-pool-"), new ThreadPoolExecutor.AbortPolicy());
for (int i = 0; i < 100; i++) {
          
   
    executor.execute(() -> log.debug("执行中 >>>"));
}

执行结果

2022-06-09 18:24:17.531 [async-task-pool-1] DEBUG c.m.idemo.ThreadPoolTest - 执行中 >>>
2022-06-09 18:24:17.531 [async-task-pool-2] DEBUG c.m.idemo.ThreadPoolTest - 执行中 >>>
2022-06-09 18:24:17.531 [async-task-pool-3] DEBUG c.m.idemo.ThreadPoolTest - 执行中 >>>
2022-06-09 18:24:17.531 [async-task-pool-4] DEBUG c.m.idemo.ThreadPoolTest - 执行中 >>>
...
...