（一）配置类注册成Bean
 
package com.supconit.data.integration.service.threadPool;/**
 * Created by dell on 2019/10/24.
 */

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ThreadPoolExecutor;

/**
 * @author:huangshichang@supconit
 * @date: 2019-10-24 16:01
 * @desc:线程池配置类
 */
@Configuration
@EnableAsync
public class ThreadPoolConfig {
    @Bean
    public TaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // 设置核心线程数
        executor.setCorePoolSize(5);
        // 设置最大线程数
        executor.setMaxPoolSize(10);
        // 设置队列容量
        executor.setQueueCapacity(20);
        // 设置线程活跃时间（秒）
        executor.setKeepAliveSeconds(60);
        // 设置默认线程名称
        executor.setThreadNamePrefix("hello-");
        // 设置拒绝策略
        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        // 等待所有任务结束后再关闭线程池
        executor.setWaitForTasksToCompleteOnShutdown(true);
        return executor;
    }
}
 
（二 ）Service层 ， 有两个异步方法，一个是新增日志，带返回值，一个是修改日志，不带返回值
 
public interface  TaskLogService {
    /**
     * 插入任务运行日志
     * @param taskId
     * @param projeceSpaceId
     * @return
     */
    Future<String> insertTaskLog(Integer taskId, Integer projeceSpaceId);
    /**
     * 修改任务运行日志
     * @param logId
     * @param appendLog
     * @return
     */
    void updateTaskLog(Integer logId,String appendLog);
}
 
（三）ServiceImpl层，记得加上@Async注解，taskExecutor这个是刚才线程池生成的bean
 
@Service
public class TaskLogServiceImpl implements TaskLogService {
    @Autowired
    private TaskLogMapper taskLogMapper;

    @Async("taskExecutor")
    public Future<String> insertTaskLog(Integer taskId, Integer projeceSpaceId){
        TaskLog taskLog = new TaskLog();
        taskLog.setCreateTime(new Date());
        taskLog.setProjectSpaceId(projeceSpaceId);
        taskLog.setTaskId(taskId);
        taskLogMapper.insertSelective(taskLog);
        return new AsyncResult<String>(taskLog.getId().toString());
    }


    @Async("taskExecutor")
    public void updateTaskLog(Integer logId, String appendLog){
        TaskLog taskLog =   taskLogMapper.selectByPrimaryKey( logId ) ;
        if ( null != taskLog ){
            String log = (taskLog.getLog() == null) ? "" : taskLog.getLog();
            if (appendLog != null) {
                log += "\n" + appendLog;
                taskLog.setLog(log);
                taskLog.setLastUpdateLog(new Date());
                taskLogMapper.updateByPrimaryKeyWithBLOBs(taskLog);
            }
        }
    }

}

 
（四）
 想获得异步的返回值，如下
 Future future = taskLogServiceImpl.insertTaskLog(taskId,projectSpaceId);
 String taskLogId = future.get();

前言
 
遇到这样一个需求：调用接口，返回一个新闻列表，再循环这个新闻列表，用每个新闻的id异步请求这个新闻的视频地址，这就需要在循环里调用接口。如果用for循环，接口还没请求完成，for循环就已经执行完了。所以改成promise去处理。
 
开始
 
整体思路就是：先存数组，然后循环生成每一个promise，然后用promise.all来调用，then的时候返回的是一个结果数组。
 
1、首先定义循环里的异步请求
 
getInfo(item ,index){
			return new Promise((resolve,reject) => {
				axios.post('/videoUrl',{id:item.id}).then(res=>{
					let url = res.data;
					resolve({id:item.id,url:url})
				})
			})
		}
 
2、newsList为开始接口获取的新闻列表，对新闻列表进行循环，得到一个promise数组。
 
let promiseArr = this.newsList.map((item,index) => {
				    return this.getInfo(item, index)
				 })
 
3、用promise.all来调。
 
Promise.all(promiseArr).then(value=>{
						console.log(value);
					 //value:[{id: 1, url: "xxxxx"},
					// 		  {id: 2, url: "xxxxx"},
					// 		  {id: 3, url: "xxxxx"}]
						this.newsList = value;
					})
 
这样就拿到了包含新闻视频地址的新闻列表。
 
全部代码
 
<script>
export default {
	name: 'empty',
	data () {
		return {
			newsList:[]//新闻列表
		}
	},
	methods:{
			getNewsList(){
				axios.get('/newsList').then(res=>{
					this.newsList = res.data;//newsList = [{id:1},{id:2},{id:3}];
					let promiseArr = this.newsList.map((item,index) => {
						return this.getInfo(item, index)
					})
					Promise.all(promiseArr).then(value=>{
						console.log(value);
					 //value:[{id: 1, url: "xxxxx"},
					// 		  {id: 2, url: "xxxxx"},
					// 		  {id: 3, url: "xxxxx"}]
						this.newsList = value;
					})
				})
			},
			// 通过新闻id请求新闻视频地址
			getInfo(item ,index){
				return new Promise((resolve,reject) => {
					axios.post('/videoUrl',{id:item.id}).then(res=>{
						let url = res.data;
						resolve({id:item.id,url:url})
					})
				})
			}
	},
	mounted(){
		this.getNewsList();
	}
}
</script>
 
后记
 
1、首先关于后台修改接口，正常返回应该是newsList里就返回了视频地址，协商过就是需要单独去调用。
 2、这个问题的解决花费了时间，特此记录。文章参考javascript for循环+异步请求导致请求顺序不一致

 
问题描述：for循环中，异步调用后端接口无效（同时执行所有任务，导致页面卡死）
 
 
提示：循环不能是异步的，for循环是同步任务，内部的异步任务会在for循环执行完成后执行
 
 
解决方法：循环中使用递归。使用递归函数在事件循环的单独轮次中执行迭代，在事件循环的单独轮次中执行递归，不会导致调用栈溢出。
 
 
（）事件循环的每个轮次中调用其他事件处理程序的调用栈最初是空的）
 
 
 
 
 
这个问题涉及事件循环：
 
 
1、所有同步任务都在主线程上执行，形成一个“执行栈”
 
 
2、主线程之外，还存在一个“任务队列”，只要异步任务有了结果，就在“任务队列”中放置一个事件
 
 
3、一旦执行栈的所有同步任务完成，系统就读取“任务队列”对应异步任务，结束等待状态，进入执行栈，开始执行（执行异步回调）
 
 
4、主线程不断重复（3）步骤
 
 
 
 
转载于:https://www.cnblogs.com/shuhaonb/p/10364896.html

因为异步接口是异步执行，主线程的函数都执行完才执行异步执行栈中的函数，所以要想在异步接口获取数据后在其他函数中使用该数据需要在内部写callback回调函数。（将异步接口改为同步也是一种方式，但是不推荐，同步容易造成页面假死）