Springbootスレッドプールを使用したサブスレッド戻り値処理

1、@Bean方式でスレッドプールを作成し、コンテナに注入する

/**
 * FileName: com.XXX.cloud.datas.config
 * Author: XXX
 * Date: 2019/7/4 13:36
 * Description:    
 * History:
 *                               
 *                                                  
 */
package com.XXX.cloud.datas.config;

import com.google.common.util.concurrent.ThreadFactoryBuilder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;

import java.util.concurrent.*;

/**
 * @Description:      
 * @ClassName: ThreadExecutorConfig
 * @Author: XXX
 * @Date: 2019/7/4 13:36
 * @Version: 1.0
 */
@Configuration
@EnableAsync
public class ThreadExecutorConfig {

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

    /**
     *      
     */
    private int corePoolSize = Runtime.getRuntime().availableProcessors();
    /**
     *      
     */
    private int maxPoolSize = Integer.MAX_VALUE;
    /**
     *       
     */
    private Long keepAliveTime = 60L;
    /**
     *     
     */
    private SynchronousQueue synchronousQueue = new SynchronousQueue<>();
    /**
     *     
     */
    private ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("datas-thread-%d").build();

    @Bean
    public ExecutorService myDataThreadPool() {
        logger.info("     ===>  ");
        /**
         *      
         * Runtime.getRuntime().availableProcessors()
         */
        ExecutorService threadPool = new ThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, synchronousQueue, namedThreadFactory);
        logger.info("     ===>  ");
        return threadPool;
    }
}

2、サービスにスレッドプールを注入する

@Resource(name = "myDataThreadPool")
private ExecutorService threadPool;

3、内部クラスの作成(内部クラスを使用しなくてもよい)、サブスレッド呼び出し方法

/**
  *   1->     (      )
  * @author XXX
  * @date 2019/5/31 16:40
  * @version 1.0
  */
class MyCallable implements Callable {
    private Long appRunDbType;
    private Long companyId;
    private Long userId;
    public MyCallable(Long appRunDbType, Long companyId, Long userId) {
        this.appRunDbType = appRunDbType;
        this.companyId = companyId;
        this.userId = userId;
    }
    @Override
    public Object call() throws Exception {
        return synchrCreateDb(appRunDbType, companyId, userId);
    }
}
/**
  *        
  * @author XXX
  * @date 2019/6/13 16:24
  * @version 1.0
  */
public String synchrCreateDb(Long appRunDbType, Long companyId, Long userId) {
     XXX...
}

4、スレッドプールへのタスクの送信

public String createDb(Long appRunDbType,Long userId,Long companyId) {
    //             
    MyCallable myCallable = new MyCallable(appRunDbType, companyId, userId);
    //        Future  
    Future future = threadPool.submit(myCallable);
    try {
        //  Future           ,   
        return future.get().toString();
    } catch (Exception e) {
        e.printStackTrace();
    }
    return null;
}