springboot ThreadPoolTaskExecutor示例

以下是一个Spring Boot中使用ThreadPoolTaskExecutor的示例代码：

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

@Component
public class MyService {

    private final ThreadPoolTaskExecutor taskExecutor;

    public MyService(ThreadPoolTaskExecutor taskExecutor) {
        this.taskExecutor = taskExecutor;
    }

    public void executeAsyncTask() {
        taskExecutor.execute(() -> {
            // 在这里编写异步任务的代码
            System.out.println("执行异步任务");
        });
    }
}

在以上示例中，我们通过依赖注入的方式将ThreadPoolTaskExecutor注入到了MyService类中。然后我们可以调用executeAsyncTask方法来执行一个异步任务。在executeAsyncTask方法中，我们使用taskExecutor.execute方法来提交一个任务给线程池进行执行。在这个例子中，我们简单地打印了一条消息来表示异步任务的执行。

注意，你需要确保已经创建并配置了ThreadPoolTaskExecutor bean，可以参考你的项目中的ExecutorConfig类来配置ThreadPoolTaskExecutor的相关属性，比如corePoolSize（核心线程数）、maxPoolSize（最大线程数）、queueCapacity（队列容量）等等。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* *3* [SpringBoot中使用ThreadPoolExecutor和ThreadPoolTaskExecutor线程池的方法和区别](https://blog.csdn.net/qq_40386113/article/details/127581333)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_2"}}] [.reference_item style="max-width: 100%"]
[ .reference_list ]