如何自定义Java Executor执行器

在Java中，Executor接口和它的实现类（如ThreadPoolExecutor）提供了一种将任务提交给线程池执行的方式。自定义一个Java Executor执行器通常涉及以下几个步骤：

1. 选择合适的线程池类型：Java提供了几种不同类型的线程池，例如FixedThreadPool、CachedThreadPool、SingleThreadExecutor和ScheduledThreadPool。根据你的需求选择合适的线程池类型。

2. 配置线程池参数：如果你选择的是ThreadPoolExecutor，你可以配置核心线程数、最大线程数、线程空闲时间、任务队列等参数。

3. 自定义线程工厂：你可以提供一个自定义的ThreadFactory来创建线程，这样可以为线程设置更有意义的名字、优先级等。

4. 自定义拒绝策略：当线程池无法接受新任务时，它会调用拒绝策略。你可以自定义拒绝策略来决定如何处理这种情况。

5. 提交任务：使用execute(Runnable)或submit(Callable)方法提交任务给执行器。

下面是一个简单的例子，展示了如何自定义一个ThreadPoolExecutor：

import java.util.concurrent.*;

public class CustomExecutorExample {
    public static void main(String[] args) {
        // 创建一个自定义的线程工厂
        ThreadFactory customThreadFactory = new ThreadFactory() {
            private int count = 0;

            @Override
            public Thread newThread(Runnable r) {
                Thread t = new Thread(r);
                t.setName("CustomThread-" + count++);
                t.setPriority(Thread.NORM_PRIORITY);
                return t;
            }
        };

        // 创建一个自定义的拒绝策略
        RejectedExecutionHandler customRejectionHandler = new RejectedExecutionHandler() {
            @Override
            public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                System.out.println("Task " + r.toString() + " rejected from " + executor.toString());
            }
        };

        // 创建一个ThreadPoolExecutor实例
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                2, // 核心线程数
                4, // 最大线程数
                60L, // 线程空闲时间
                TimeUnit.SECONDS, // 时间单位
                new LinkedBlockingQueue<>(10), // 任务队列
                customThreadFactory, // 自定义线程工厂
                customRejectionHandler // 自定义拒绝策略
        );

        // 提交任务给执行器
        for (int i = 0; i < 10; i++) {
            final int taskNumber = i;
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
                }
            });
        }

        // 关闭执行器
        executor.shutdown();
    }
}

在这个例子中，我们创建了一个核心线程数为2，最大线程数为4的线程池，并且设置了一个自定义的线程工厂和拒绝策略。然后我们提交了10个任务给这个线程池。当线程池无法接受新任务时，它会调用我们自定义的拒绝策略。

请注意，当你的应用程序结束时，你应该调用shutdown()方法来优雅地关闭线程池，这样可以确保所有已提交的任务都有机会执行完毕。如果你想要立即关闭线程池，可以使用shutdownNow()方法，但这可能会导致正在执行的任务被中断。