在SpringBoot專案中配置和使用多執行緒非常簡單,步驟如下.

1.多執行緒配置:

/**
 * 執行緒池配置
 * 
 * @author dongchuan
 */
@Configuration
@EnableAsync
public class AsyncTaskConfig implements AsyncConfigurer {

    private static final Logger logger = LoggerFactory.getLogger(AsyncTaskConfig.class);

    /**
     * ThredPoolTaskExcutor的處理流程 當池子大小小於corePoolSize，就新建執行緒，並處理請求
     * 當池子大小等於corePoolSize，把請求放入workQueue中，池子裡的空閒執行緒就去workQueue中取任務並處理
     * 當workQueue放不下任務時，就新建執行緒入池，並處理請求，如果池子大小撐到了maximumPoolSize，就用RejectedExecutionHandler來做拒絕處理
     * 當池子的執行緒數大於corePoolSize時，多餘的執行緒會等待keepAliveTime長時間，如果無請求可處理就自行銷燬
     */
    @Override
    @Bean(name = "taskExecutor")
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        // 最小執行緒數(核心執行緒數)
        taskExecutor.setCorePoolSize(4);
        // 最大執行緒數
        taskExecutor.setMaxPoolSize(8);
        // 等待佇列(佇列最大長度)
        taskExecutor.setQueueCapacity(16);
        taskExecutor.initialize();
        return taskExecutor;
    }

    /**
     * 非同步異常處理
     * 
     * @return
     */
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SpringAsyncExceptionHandler();
    }

    class SpringAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {
        @Override
        public void handleUncaughtException(Throwable throwable, Method method, Object... obj) {
            logger.error("Exception occurs in async method", throwable.getMessage());
        }
    }
}
 

2.呼叫demo:

@Controller
@Slf4j
public class TestController {

    @Autowired
    private ThreadPoolTaskExecutor taskExecutor;

    @RequestMapping("/test/asyn")
    @ResponseBody
    public String asyn() {
		taskExecutor.execute(() -> {
			try {
				log.info("非同步開始" + System.currentTimeMillis());
				Thread.sleep(10000);
				log.info("非同步結束" + System.currentTimeMillis());
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		});
		return "kerry dong";
    }
 

用postman請求介面會發現直接返回字串(並沒有等待10秒),說明taskExecutor.execute()方法內的程式碼是非同步執行的.