如何自定义Java Executor线程工厂

在Java中，ExecutorService 是一个用于管理和控制线程执行的接口。默认情况下，当你使用 Executors 工厂方法创建 ExecutorService 时，它会使用一个默认的线程工厂来创建线程。但是，你可以通过实现 ThreadFactory 接口来自定义线程工厂，以便为创建的线程设置特定的属性，例如名称、优先级、守护状态等。

以下是如何自定义Java Executor 线程工厂的步骤：

1. 实现 ThreadFactory 接口： 创建一个类，实现 ThreadFactory 接口，并重写 newThread(Runnable r) 方法。在这个方法中，你可以配置新创建的线程。

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

public class CustomThreadFactory implements ThreadFactory {
    private final String namePrefix;
    private final AtomicInteger threadNumber = new AtomicInteger(1);
    private final ThreadGroup group;

    public CustomThreadFactory(String namePrefix) {
        SecurityManager s = System.getSecurityManager();
        group = (s != null) ? s.getThreadGroup() : Thread.currentThread().getThreadGroup();
        namePrefix = namePrefix + "-thread-";
    }

    @Override
    public Thread newThread(Runnable r) {
        Thread t = new Thread(group, r, namePrefix + threadNumber.getAndIncrement(), 0);
        if (t.isDaemon())
            t.setDaemon(false);
        if (t.getPriority() != Thread.NORM_PRIORITY)
            t.setPriority(Thread.NORM_PRIORITY);
        return t;
    }
}

2. 使用自定义线程工厂创建 ExecutorService： 使用 Executors.newFixedThreadPool(int nThreads, ThreadFactory threadFactory) 方法来创建一个固定大小的线程池，并传入你的自定义线程工厂。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CustomExecutorServiceExample {
    public static void main(String[] args) {
        CustomThreadFactory customThreadFactory = new CustomThreadFactory("MyCustomThread");
        ExecutorService executorService = Executors.newFixedThreadPool(5, customThreadFactory);

        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            executorService.submit(() -> {
                System.out.println("Running in " + Thread.currentThread().getName());
            });
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

在上面的例子中，我们创建了一个名为 MyCustomThread 的自定义线程工厂，并将其用于创建一个固定大小为5的线程池。当我们向线程池提交任务时，每个任务都会在一个具有自定义名称前缀的新线程中运行。

通过这种方式，你可以完全控制线程的创建过程，包括它们的名称、优先级和其他属性。这对于调试、日志记录和资源管理非常有用。