springboot使用多线程处理高并发接口_飞道的博客

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

2022-11-10 10:10 556人阅读评论(0)

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);
     
    
   
    
     
    
    
     
          }
     
    
   
    
     
    
    
     
      }