Springboot?配置線程池創(chuàng)建線程及配置?@Async?異步操作線程池詳解

更新時間：2022年09月21日 15:33:03 作者：繁華盡頭滿是殤

這篇文章主要介紹了Springboot?配置線程池創(chuàng)建線程及配置?@Async?異步操作線程池詳解，文章圍繞主題展開詳細的內容介紹，具有一定的參考價值，需要的小伙伴可以參考一下

前言

眾所周知，創(chuàng)建顯示線程和直接使用未配置的線程池創(chuàng)建線程，都會被阿里的大佬給diss，所以我們要規(guī)范的創(chuàng)建線程。

至于 @Async 異步任務的用處是不想等待方法執(zhí)行完就返回結果，提高軟件前臺響應速度，一個程序中會用到很多異步方法，所以需要使用線程池管理，防止影響性能。

一、創(chuàng)建一個Springboot Web項目

需要一個Springboot項目

二、新建ThreadPoolConfig

可以直接return一個內置線程池
Executors類創(chuàng)建線程池的方法歸根結底都是調用ThreadPoolExecutor類，只不過對每個方法賦值不同的參數(shù)去構造ThreadPoolExecutor對象。
newCachedThreadPool:創(chuàng)建一個可緩存的線程池，如果線程池長度超過處理需要，可靈活回收空閑線程，若無可回收，則新建線程。
newFixedThreadPool: 創(chuàng)建一個定長線程池，可控制線程最大并發(fā)數(shù)，超出的線程會在隊列中等待
newScheduledThreadPool: 創(chuàng)建一個定長線程池，支持定時及周期性任務執(zhí)行。
newSingleThreadExecutor: 創(chuàng)建一個單線程化的線程池，它只會用唯一的工作線程來執(zhí)行任務，保證所有任務按照指定順序(FIFO, LIFO, 優(yōu)先級)執(zhí)行。

也可以自己new一個ThreadPoolExecutor自定義參數(shù)

參數(shù)說明：

corePoolSize: 常駐核心線程數(shù)，如果大于0，即使本地任務執(zhí)行完也不會被銷毀
maximumPoolSize： 線程池能夠容納可同時執(zhí)行的最大線程數(shù)
keepAliveTime: 線程池中線程空閑的時間，當空閑時間達到該值時，線程會被銷毀，只剩下 corePoolSize 個線程數(shù)量。
unit： 空閑時間的單位。一般以TimeUnit類定義時分秒。
workQueue: 當請求的線程數(shù)大于 corePoolSize 時，線程進入該阻塞隊列。
threadFactory: 線程工廠，用來生產(chǎn)一組相同任務的線程，同時也可以通過它增加前綴名，虛擬機棧分析時更清晰
handler: 執(zhí)行拒絕策略，當 workQueue 已滿，且超過maximumPoolSize 最大值，就要通過這個來處理，比如拒絕，丟棄等，這是一種限流的保護措施。

阻塞隊列的實現(xiàn)類：

LinkedBlockingQueue 無界隊列，當不指定隊列大小時，將會默認為Integer.MAX_VALUE大小的隊列，因此大量的任務將會堆積在隊列中，最終可能觸發(fā)OOM。
ArrayBlockingQueue 有界隊列，基于數(shù)組的先進先出隊列，此隊列創(chuàng)建時必須指定大小。
PriorityBlockingQueue 有界隊列，基于優(yōu)先級任務的，它是通過Comparator決定的。
SynchronousQueue 這個隊列比較特殊，它不會保存提交的任務，而是將直接新建一個線程來執(zhí)行新來的任務

處理策略Handler：

AbortPolicy 默認的拒絕策略，拋RejectedExecutionException異常
DiscardPolicy 相當大膽的策略，直接丟棄任務，沒有任何異常拋出
DiscardOldestPolicy 丟棄最老的任務，其實就是把最早進入工作隊列的任務丟棄，然后把新任務加入到工作隊列
CallerRunsPolicy 提交任務的線程自己去執(zhí)行該任務

線程池的關閉：

shutdown() : 不會立刻終止線程，等所有緩存隊列中的任務都執(zhí)行完畢后才會終止。
shutdownNow() : 立即終止線程池，并嘗試打斷正在執(zhí)行的任務，并且清空任務緩存隊列，返回尚未執(zhí)行的任務

package com.xuyijie.threadpooldemo.config;

import org.springframework.boot.SpringBootConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.*;

/**
 * @author 徐一杰
 * @date 2022/9/20 13:05
 * @description 配置線程池
 */
@SpringBootConfiguration
@EnableAsync
public class ThreadPoolConfig {

    @Bean
    public ExecutorService getThreadPool(){
        ExecutorService threadPool = new ThreadPoolExecutor(2,5,
                1L, TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(3),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy());
        return threadPool;
//        return Executors.newCachedThreadPool();
    }

    /**
     * 下面的配置是配置Springboot的@Async注解所用的線程池
     */
    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //獲取到cpu內核數(shù)
        int i = Runtime.getRuntime().availableProcessors();
        // 設置線程池核心容量
        executor.setCorePoolSize(i);
        // 設置線程池最大容量
        executor.setMaxPoolSize(i * 2);
        // 設置任務隊列長度
        executor.setQueueCapacity(200);
        // 設置線程超時時間
        executor.setKeepAliveSeconds(60);
        // 設置線程名稱前綴
        executor.setThreadNamePrefix("xyjAsyncPool-");
        // 設置任務丟棄后的處理策略,當poolSize已達到maxPoolSize，如何處理新任務（是拒絕還是交由其它線程處理）,CallerRunsPolicy：不在新線程中執(zhí)行任務，而是由調用者所在的線程來執(zhí)
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }

}

使用此線程池時直接注入ExecutorService，然后：

executorService.execute(() -> {
?try {
String message = redisUtil.listRightPop(“queue:queueData”, 5, TimeUnit.SECONDS);
System.out.println(“接收到了消息message” + message);
} catch (Exception ex) {
date.set(simpleDateFormat.format(new Date()));
System.out.println(“隊列阻塞超時-” + date + ex.getMessage());
} finally {
?date.set(simpleDateFormat.format(new Date()));
System.out.println(“線程銷毀-” + date);
executorService.shutdown();
}
?});

三、新建controller測試

package com.xuyijie.threadpooldemo.controller;

import com.xuyijie.threadpooldemo.async.AsyncMethod;
import org.springframework.beans.factory.annotation.Autowired;
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.ExecutorService;

/**
 * @author 徐一杰
 * @date 2022/9/20 10:30
 * @description
 */
@RestController
@RequestMapping("/test")
public class TestController {

    @Autowired
    private ExecutorService executorService;
    @Autowired
    private AsyncMethod asyncMethod;
    
    @GetMapping("/helloThread")
    public void helloThread(){
        executorService.execute(() -> {
            for (int i = 0;i < 100;i++){
                System.out.println("111");
            }
        });
        executorService.execute(() -> {
            for (int i = 0;i < 100;i++){
                System.out.println("222");
            }
        });
    }
	
	@GetMapping("/helloAsync")
    public String helloAsync(){
    	// 這個方法是異步的
        asyncMethod.print();
        System.out.println("print方法還在循環(huán)，但我已經(jīng)可以執(zhí)行了");
        return "print方法還在循環(huán)，但我已經(jīng)可以執(zhí)行了";
    }

}

AsyncMethod.java

package com.xuyijie.threadpooldemo.async;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

/**
 * @author 徐一杰
 * @date 2022/9/20 15:10
 * @description 異步方法
 */
@Component
public class AsyncMethod {

	/**
     * 異步方法，如果@Async加在類的上面，則整個類中的方法都是異步的
     */
    @Async
    public void print(){
        for (int i = 0;i < 100;i++){
            System.out.println(i);
        }
    }
}

四、演示結果

首先演示 helloThread 這個接口，創(chuàng)建了2個線程，發(fā)現(xiàn)他們并發(fā)執(zhí)行，成功

再演示 helloAsync 這個接口，發(fā)現(xiàn) System.out.println("print方法還在循環(huán)，但我已經(jīng)可以執(zhí)行了");這行代碼無需等待上面AsyncMethod中的 print 方法執(zhí)行完畢，就可以開始執(zhí)行，說明 print 方法是異步的，而且我輸出的日志注意看，[xyjAsyncPool - ]，我設置的線程池前綴，已經(jīng)生效了，成功