How to use thread pool task executor in Java?

In Java, ThreadPoolTaskExecutor is a class used for managing thread pools. It allows for easy creation and scheduling of asynchronous tasks.

Firstly, you need to import the ThreadPoolTaskExecutor class in your Java code.

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

Then, you can instantiate a ThreadPoolTaskExecutor object and configure the properties of the thread pool, such as core pool size, maximum pool size, and queue capacity.

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5);  // 设置核心线程数为5
executor.setMaxPoolSize(10);  // 设置最大线程数为10
executor.setQueueCapacity(25);  // 设置队列容量为25
executor.initialize();  // 初始化线程池

Next, you can use ThreadPoolTaskExecutor to submit asynchronous tasks to the thread pool for execution.

executor.execute(new Runnable() {
    @Override
    public void run() {
        // 异步任务的具体逻辑
    }
});

Alternatively, you can use the submit method of ThreadPoolTaskExecutor to submit asynchronous tasks and obtain a Future object to handle the return value of the tasks.

Future<String> future = executor.submit(new Callable<String>() {
    @Override
    public String call() throws Exception {
        // 异步任务的具体逻辑
        return "Task completed";
    }
});

try {
    String result = future.get();  // 获取任务的返回值
    System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}

Finally, when you no longer need to use the thread pool, you can call the shutdown method of the ThreadPoolTaskExecutor to close the thread pool.

executor.shutdown();

These are the basic steps for using ThreadPoolTaskExecutor. You can customize the thread pool properties according to your needs and submit asynchronous tasks as required.