需求背景

一个非主要功能特殊时期的高并发问题。该场景用到了parallelStream并发流提高查询速度，但是Java8的并发流线程池默认是ForkJoinPool，是全局共享的，任何用到了并发流的业务操作默认都是一个线程池。

问题：所有parallelStream业务操作都使用一个线程池就有可能互相影响。比如帮助中心查询用户权限+内容过滤都用到了parallelStream，相当于这些操作都在一个池子里。在并发的时候就有可能互相影响。

特点：非主要功能且在特殊时间（平时不咋用、平时不会集中使用）

解决方案

特殊账号用户、普通用户在不同的线程池中

@Test
   void test() {
       List<Integer> list = new ArrayList<>();
       for (int i = 0; i < 100; i++) {
           list.add(i);
       }

       list.parallelStream().forEach((i) -> {
           System.out.println(Thread.currentThread().getName() + "........XXX");
           try {
               Thread.sleep(500000L);
           } catch (InterruptedException e) {
               e.printStackTrace();
           }
       });

   }

   @Test
   void testPrivate() {
       List<Integer> list = new ArrayList<>();
       for (int i = 0; i < 100; i++) {
           list.add(i);
       }
       ForkJoinPool customThreadPool = new ForkJoinPool(4);
       customThreadPool.submit(
               () -> list.parallelStream().forEach((i) -> {
                   System.out.println(Thread.currentThread().getName() + "........XXX");
                   try {
                       Thread.sleep(50000L);
                   } catch (InterruptedException e) {
                       e.printStackTrace();
                   }
               }));
       // 自定义的ForkJoinPool不会使用主线程，所以需要主线程也sleep一下，方便查看控制台数据
       try {
           Thread.sleep(500000L);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
   }