springboot使用多线程处理高并发接口

1、同步转异步，单条转批量

2、异步线程获取数据

关于Future同步、异步获取线程执行结果分析_红鲤鱼与彩虹的博客-CSDN博客

多任务并行、利用CompletionService计算任务执行结果的和，并优先获取最快执行完毕的任务返回值，使用于无访问顺序的代码。

import java.util.concurrent.*;
 
/**
 * 多任务，用时最小，利用completionService实现
 *
 * 与 invokeAll不同的是，
 * CompletionService.take().get()通过消息队列生产-消费模式获取最先执行完的结果，不会按提交顺序获取结果
 */
public class MultiTaskCompletionService {
 
    public static void main(String[] args) {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                10,
                20,
                100,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(100),
                new ThreadPoolExecutor.AbortPolicy()); //拒绝策略
        CompletionService<Integer> service = new ExecutorCompletionService<>(executor);
 
        long start = System.currentTimeMillis();
        for (int i =3;i>0;i--){
            service.submit(new Task(i));
        }
        int sum=0;
        for (int i =0;i<3;i++){
            try {
                int value = service.take().get();
                System.out.println("第"+i +"个返回的任务id是：" + value);
                sum+=value;
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (ExecutionException e) {
                e.printStackTrace();
            }
        }
        System.out.println(sum);
        System.out.println(System.currentTimeMillis()-start);
    }
}
 

3、阻塞队列压测性能比较

Java线程池实验：ArrayBlockingQueue和LinkedBlockingQueue性能测试_trigger333的博客-CSDN博客_arrayblockingqueue 性能

ArrayBlockingQueue 和 LinkedBlockingQueue 性能测试与分析_阿拉的梦想的博客-CSDN博客_blockingqueue 效率

Java多线程——并发测试 | HeapDump性能社区

结论：

队列设置长有利于提高并发，目前1w他长度还行。

ArrayBlockingQueue 要比LinkedBlockingQueue 效率高。

当线程增加到cpu的个数的时候，吞吐率会达到顶峰，然后再增加线程吞吐率不生反而下降，当然没有很大的下降，这是因为，当线程增多的时候，大部分时间耗费在阻塞和解除阻塞上面了。

4、提高接口性能方法

聊聊接口性能优化的11个小技巧 | HeapDump性能社区