Spring Boot使用線(xiàn)程池創(chuàng)建多線(xiàn)程的完整示例

更新時(shí)間：2025年03月18日 10:46:38 作者：翱翔-藍(lán)天

在 Spring Boot 2 中,可以使用 @Autowired 注入線(xiàn)程池（ThreadPoolTaskExecutor 或 ExecutorService）,從而管理線(xiàn)程的創(chuàng)建和執(zhí)行,以下是使用 @Autowired 方式注入線(xiàn)程池的完整示例,感興趣的朋友一起看看吧

1. 通過(guò) @Autowired 注入 ThreadPoolTaskExecutor

步驟 1：配置線(xiàn)程池

創(chuàng)建 ThreadPoolTaskExecutor 的 @Bean 配置：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import java.util.concurrent.Executor;
@Configuration
public class ThreadPoolConfig {
    @Bean(name = "customTaskExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);  // 核心線(xiàn)程數(shù)
        executor.setMaxPoolSize(10);  // 最大線(xiàn)程數(shù)
        executor.setQueueCapacity(25); // 任務(wù)隊(duì)列容量
        executor.setThreadNamePrefix("Async-Executor-"); // 線(xiàn)程名前綴
        executor.initialize();
        return executor;
    }
}

步驟 2：使用 @Autowired 注入線(xiàn)程池

在 Service 層，通過(guò) @Autowired 注入 ThreadPoolTaskExecutor 并執(zhí)行任務(wù)：

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Service;
import java.util.concurrent.Future;
@Service
public class AsyncTaskService {
    private static final Logger logger = LoggerFactory.getLogger(AsyncTaskService.class);
      @Autowired
    @Qualifier("customTaskExecutor") // 通過(guò) @Qualifier 指定 Bean 名稱(chēng)
    private ThreadPoolTaskExecutor customTaskExecutor;
    // 提交異步任務(wù)
    public void runAsyncTask() {
        customTaskExecutor.execute(() -> {
            logger.info("異步任務(wù)執(zhí)行，線(xiàn)程名：{}", Thread.currentThread().getName());
            try {
                Thread.sleep(2000); // 模擬耗時(shí)任務(wù)
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.info("異步任務(wù)完成，線(xiàn)程名：{}", Thread.currentThread().getName());
        });
    }
    // 提交帶返回值的異步任務(wù)
    public Future<String> runAsyncTaskWithResult() {
        return customTaskExecutor.submit(() -> {
            logger.info("執(zhí)行帶返回值的異步任務(wù)，線(xiàn)程名：{}", Thread.currentThread().getName());
            Thread.sleep(2000);
            return "任務(wù)完成";
        });
    }
}

步驟 3：在 Controller 中調(diào)用

在 Controller 層，通過(guò) @Autowired 調(diào)用 AsyncTaskService：

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.Future;
@RestController
@RequestMapping("/task")
public class AsyncTaskController {
    @Autowired
    private AsyncTaskService asyncTaskService;
    @GetMapping("/run")
    public String runTask() {
        asyncTaskService.runAsyncTask();
        return "任務(wù)已提交";
    }
    @GetMapping("/runWithResult")
    public String runTaskWithResult() throws Exception {
        Future<String> result = asyncTaskService.runAsyncTaskWithResult();
        return "任務(wù)結(jié)果：" + result.get();
    }
}

2. 通過(guò) @Autowired 注入 ThreadPoolTaskScheduler（適用于定時(shí)任務(wù)）

步驟 1：配置 ThreadPoolTaskScheduler

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
@Configuration
public class TaskSchedulerConfig {
    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5);  // 線(xiàn)程池大小
        scheduler.setThreadNamePrefix("Scheduled-Task-");
        scheduler.initialize();
        return scheduler;
    }
}

步驟 2：在 Service 中使用 @Autowired注入

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Service;
import java.util.concurrent.ScheduledFuture;
@Service
public class ScheduledTaskService {
    private static final Logger logger = LoggerFactory.getLogger(ScheduledTaskService.class);
    @Autowired
    private ThreadPoolTaskScheduler taskScheduler;
    public void scheduleTask() {
        ScheduledFuture<?> future = taskScheduler.scheduleAtFixedRate(() -> {
            logger.info("執(zhí)行定時(shí)任務(wù)，線(xiàn)程名：{}", Thread.currentThread().getName());
        }, 5000);
    }
}

步驟 3：在 Controller 中調(diào)用

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/schedule")
public class ScheduleTaskController {
    @Autowired
    private ScheduledTaskService scheduledTaskService;
    @GetMapping("/start")
    public String startScheduledTask() {
        scheduledTaskService.scheduleTask();
        return "定時(shí)任務(wù)已啟動(dòng)";
    }
}

3. 通過(guò) @Autowired 注入 ExecutorService

如果你更喜歡 Java 原生的 ExecutorService，可以使用 @Bean 配置：

步驟 1：定義 ExecutorService 線(xiàn)程池

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@Configuration
public class ExecutorServiceConfig {
    @Bean
    public ExecutorService fixedThreadPool() {
        return Executors.newFixedThreadPool(5);
    }
}

步驟 2：在 Service 中注入 ExecutorService

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import java.util.concurrent.ExecutorService;
@Service
public class ExecutorServiceTask {
    private static final Logger logger = LoggerFactory.getLogger(ExecutorServiceTask.class);
    @Autowired
    private ExecutorService executorService;
    public void executeTask() {
        executorService.execute(() -> {
            logger.info("執(zhí)行任務(wù)，線(xiàn)程名：{}", Thread.currentThread().getName());
        });
    }
}

步驟 3：在 Controller 中調(diào)用

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/executor")
public class ExecutorServiceController {
    @Autowired
    private ExecutorServiceTask executorServiceTask;
    @GetMapping("/run")
    public String runTask() {
        executorServiceTask.executeTask();
        return "任務(wù)已提交";
    }
}

總結(jié)

方式	適用場(chǎng)景	配置方式
`ThreadPoolTaskExecutor`	普通異步任務(wù) (`@Async` 或 `execute`)	`@Autowired private ThreadPoolTaskExecutor`
`ThreadPoolTaskScheduler`	定時(shí)任務(wù)	`@Autowired private ThreadPoolTaskScheduler`
`ExecutorService`	原生 Java 線(xiàn)程池	`@Autowired private ExecutorService`