spring5 webflux测试

@Configuration
public class RouterFunctionConfiguration {

    @Bean
//    @Autowired
    public RouterFunction<ServerResponse> personFindAll(UserRepository userRepository){


        return RouterFunctions.route(RequestPredicates.GET("/person/find/all"),
                request ->{
                    Collection<User> users = userRepository.findAll();

                    Flux<User> userFlux = Flux.fromIterable(users);
                    return ServerResponse.ok().body(userFlux,User.class);
                });
    }
}

@Test
public void threadTestOrderBy() throws InterruptedException {

    final Long id=141284830240768L;
    int threadCount=100000;
    final CountDownLatch begin = new CountDownLatch(1);
    final CountDownLatch end = new CountDownLatch(threadCount);
    final int[] result={0,0};
    final Object lock = new Object();
    ExecutorService executorService = Executors.newFixedThreadPool(100);
    Long time1=System.currentTimeMillis();
    for (int i = 0; i < threadCount; i++) {
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    begin.await();
                    HttpParamsVo httpParamsVo = new HttpParamsVo(new HttpSecretVo(appKey,appSecret),params);
                    String resultS = HttpClientSecretSendUtil.get(url, httpParamsVo);
                    synchronized(lock){
                        result[0]++;
                    }
                } catch (Exception ex) {
                    synchronized(lock) {
                        result[1]++;
                    }
                    ex.printStackTrace();
                }finally{
                    end.countDown();
                }
            }
        });
        executorService.submit(thread);
    }
    System.out.println(threadCount+"个线程开始");
    begin.countDown();
    end.await();
    Long time2=System.currentTimeMillis();
    System.out.println("耗时: "+(time2-time1)/1000+"秒");
    System.out.println(threadCount+"个线程更新结束");
    System.out.println("成功"+result[0]+",失败"+result[1]);
}

@GetMapping("/person/find/all")
    @ResponseBody
    public Collection<User> findAll(){
        return this.userRepository.findAll();
    }