ThreadPoolTaskExecutor简介说明

ThreadPoolTaskExecutor简介

`ThreadPoolTaskExecutor`是Spring框架提供的一个线程池实现类
    用于执行异步任务
	它是对Java原生`ThreadPoolExecutor`封装
	提供更简洁的配置方式和与Spring集成的能力

`ThreadPoolTaskExecutor`主要特点和功能

1.主要特点
   -基于Java原生线程池:
        `ThreadPoolTaskExecutor`内部使用Java
		  `ThreadPoolExecutor` 来管理线程
   -Spring 集成:
         它是一个 Spring Bean，
		   可以轻松地通过 Spring 的配置文件或注解进行配置和管理
   -灵活配置:
        支持多种线程池参数的配置
		 如核心线程数、最大线程数、队列容量等。
   -异步任务执行:
        可以用来执行异步任务
		支持回调函数和任务超时处理

ThreadPoolTaskExecutor常用配置参数

| 参数名               | 描述                                                         |
|----------------------|--------------------------------------------------------------|
| `corePoolSize`       | 线程池的核心线程数（默认为 1）。                             |
| `maxPoolSize`        | 线程池的最大线程数（默认为 Integer.MAX_VALUE）。             |
| `queueCapacity`      | 任务队列的容量（默认为 Integer.MAX_VALUE）。                 |
| `keepAliveSeconds`   | 线程空闲后的存活时间（默认为 60 秒）。                      |
| `threadNamePrefix`   | 线程名称前缀（便于调试和日志记录）。                       |
| `allowCoreThreadTimeOut` | 是否允许核心线程超时（默认为 false）。                   |

ThreadPoolTaskExecutor中常用方法

创建和配置 `ThreadPoolTaskExecutor`
  -`setCorePoolSize(int corePoolSize)`：
     设置核心线程数。
  -`setMaxPoolSize(int maxPoolSize)`：
     设置最大线程数。
  -`setQueueCapacity(int queueCapacity)`：
     设置任务队列的容量。
  -`setKeepAliveSeconds(int keepAliveSeconds)`：
     设置线程空闲后的存活时间。
  -`setThreadNamePrefix(String threadNamePrefix)`：
     设置线程名称前缀。
  -`initialize()`：
     初始化线程池。
  
执行任务
  -`execute(Runnable task)`：
      提交一个不返回结果的任务。
  -`submit(Callable<T> task)`：
      提交一个返回结果的任务，
	    并返回一个表示该任务的`Future`对象。
  -`submit(Runnable task)`：
     提交一个不返回结果的任务，
	   并返回一个表示该任务的`Future`对象。

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Future;

public class ThreadPoolTaskExecutorExample {
    public static void main(String[] args) throws Exception {
        // 创建 ThreadPoolTaskExecutor 实例
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(10);
        executor.setQueueCapacity(20);
        executor.setThreadNamePrefix("MyThreadPool-");
        executor.initialize();

        // 提交任务
        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            executor.execute(() -> {
                System.out.println("任务 " + taskId + " 正在执行，
				  线程名称：" + Thread.currentThread().getName());
            });
        }

        // 提交带返回值的任务
        Future<String> future = executor.submit(() -> {
            return "任务完成";
        });

        // 获取任务结果
        System.out.println("任务结果：" + future.get());

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