Java ExecutorService的线程工厂使用

Java ExecutorService 的线程工厂（ThreadFactory）允许你在创建新线程时自定义线程的属性，例如线程名称、优先级和守护状态。要使用自定义线程工厂，你需要实现 java.util.concurrent.ThreadFactory 接口，并在创建 ExecutorService 时将其作为参数传递。

以下是一个简单的示例，展示了如何创建一个自定义线程工厂并将其用于 ExecutorService：

1. 首先，创建一个实现 ThreadFactory 接口的类：

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);

    public CustomThreadFactory(String namePrefix) {
        this.namePrefix = namePrefix;
    }

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

在这个例子中，我们为线程设置了名称前缀，并使用 AtomicInteger 为每个线程分配一个唯一的编号。

2. 然后，在创建 ExecutorService 时使用自定义线程工厂：

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

public class Main {
    public static void main(String[] args) {
        CustomThreadFactory customThreadFactory = new CustomThreadFactory("MyThread-");

        ExecutorService executorService = Executors.newFixedThreadPool(5, customThreadFactory);

        for (int i = 0; i < 10; i++) {
            executorService.submit(() -> {
                System.out.println("Running task in " + Thread.currentThread().getName());
            });
        }

        executorService.shutdown();
    }
}

在这个例子中，我们创建了一个固定大小的线程池，并将自定义线程工厂传递给它。当我们提交任务时，它们将由具有自定义名称前缀的线程执行。

使用自定义线程工厂可以帮助你更好地监控和管理线程池中的线程。例如，你可以根据线程名称轻松地识别它们，或者为特定类型的任务设置不同的优先级。