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

时间:2022-11-10 07:52:56

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性能社区