springboot-線程池簡單使用

最近做項目，關於訂單創建時候因為需要調用遠程http服務獲取數據，然后校驗並寫入數據庫和修改數據庫，

導致接口效率低，所以想到實現異步操作的方式解決。

在調用遠程接口成功的時候即認為接口處理成功，返回給前段正確，並開啟線程進行數據的寫入和修改

1）添加配置類

package com.fieldsales.pos.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author :CX
 * @Date :Create in 2019/3/29 10:42
 * @Effect :線程池配置類
 */
@Configuration
@EnableAsync
@ConfigurationProperties(prefix = "async")
@Data
public class ExecutorConfig {

    private int corePoolSize;
    private int maxPoolSize;
    private int queueCapacity;
    private String namePrefix;


    @Bean(name = "asyncServiceExecutor")
    public Executor asyncServiceExecutor() {
        System.err.println("初始化線程池-----");
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //配置核心線程數
        executor.setCorePoolSize(corePoolSize);
        //配置最大線程數
        executor.setMaxPoolSize(maxPoolSize);
        //配置隊列大小
        executor.setQueueCapacity(queueCapacity);
        //配置線程池中的線程的名稱前綴
        executor.setThreadNamePrefix(namePrefix);

        // rejection-policy：當pool已經達到max size的時候，如何處理新任務
        // CALLER_RUNS：不在新線程中執行任務，而是有調用者所在的線程來執行
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //執行初始化
        executor.initialize();
        return executor;
    }


}

 

2）在配置文件中添加相應配置

#線程池配置
async:
  # 配置核心線程數
  corePoolSize: 30
  # 配置最大線程數
  maxPoolSize: 30
  # 配置隊列大小
  queueCapacity: 9999
  # 配置線程池中的線程的名稱前綴
  namePrefix: async-createOrderService-

 

3） 注入使用

    //注入線程池
    @Autowired
    private Executor asyncServiceExecutor;

//上方代碼接口調用成功 略
                // 開啟線程寫入數據庫數據
                asyncServiceExecutor.execute(new Runnable() {
                    @Override
                    public void run() {

                        //標記數據是否正常寫入 ， 如果數據寫入數據庫異常，則每10S寫出一次異常日志
                        boolean isAddOrder = false;
                        // 數據寫入的時間
                        String format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss ").format(new Date());

                      try{
                   //開啟事物寫入數據
                        } catch (Throwable throwable) {
// 接口成功但是寫入數據失敗，則間隔拋出異常
                            while (true) {
                                logger.error("嚴重錯誤------------------------------------------------------------");
                                logger.error("訂單【" + resultdata.get("orderno").toString() + "】銷售成功，但寫入現場售票數據庫失敗！");
                                logger.error("詳情表： :" + JSON.toJSONString(orderInfos));
                                logger.error("訂單表：" + JSON.toJSONString(tkttransFormModel));
                                logger.error("異常信息：" + throwable.getMessage());
                                logger.error("錯誤時間：" + format);
                                try {
                                    Thread.sleep(20000);
                                } catch (InterruptedException e) {
                                    e.printStackTrace();
                                }
                            }
                        }
                    }
                });
                return HSResponse.ok(responsMap);