java Executor执行器线程工厂自定义方法

在Java中，ExecutorService 是一个接口，它用于管理和控制线程的执行。通常，我们使用 Executors 工厂方法来创建 ExecutorService 实例，但这些方法提供的线程工厂是固定的，不能满足所有需求。因此，自定义线程工厂变得非常有用。

Java 提供了 ThreadFactory 接口，允许我们创建自定义的线程工厂。通过实现这个接口，我们可以控制线程的命名、优先级、守护状态等属性。

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

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

public class CustomThreadFactoryExample {

    public static void main(String[] args) {
        // 创建自定义线程工厂
        ThreadFactory customThreadFactory = new CustomThreadFactory();

        // 使用自定义线程工厂创建固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(5, customThreadFactory);

        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            executorService.submit(() -> {
                System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
            });
        }

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

    static class CustomThreadFactory implements ThreadFactory {
        private int counter = 0;

        @Override
        public Thread newThread(Runnable r) {
            Thread thread = new Thread(r);
            thread.setName("CustomThread-" + counter++);
            thread.setPriority(Thread.NORM_PRIORITY);
            thread.setDaemon(false);
            return thread;
        }
    }
}

代码解释

1. 自定义线程工厂类 CustomThreadFactory:

   • 实现了 ThreadFactory 接口。
   • newThread 方法用于创建新的线程。
   • 在这个方法中，我们可以设置线程的名称、优先级、守护状态等属性。

2. 创建 ExecutorService 实例:

   • 使用 Executors.newFixedThreadPool 方法创建一个固定大小的线程池。
   • 第二个参数传入自定义的线程工厂 customThreadFactory。

3. 提交任务:

   • 使用 executorService.submit 方法提交任务到线程池。
   • 每个任务打印其编号和运行线程的名称。

4. 关闭线程池:

   • 使用 executorService.shutdown 方法优雅地关闭线程池。

通过这种方式，我们可以灵活地控制线程的创建和管理，满足特定的需求。