线程池，CompletableFuture学习

   最近在做gRPC对服务端的压测，从开发身上学习到了高级用法,记录一下：

   简单说，就是长连接不释放导致TCP连接数耗尽，期望通过http2解决这个问题，也就是说，其实是用gRPC来重写了消息服务，因此需要高并发（并不是）及异步编程。

   开发review了我的代码以后，重写成这样了，记录在这里学习下。

CompletableFuture<?>[] completableFutures = new CompletableFuture[num];
ExecutorService executorService = Executors.newFixedThreadPool(200);
Stopwatch mainWatch = Stopwatch.createStarted();
for (int i = 0; i < num; i++) {
    completableFutures[i] = CompletableFuture.runAsync( () -> xxxxService.sendMessage("xielu_test")
            , executorService);
}
CompletableFuture.allOf(completableFutures).join();

线程池，CompletableFuture学习

原文：https://www.cnblogs.com/spillage/p/11422971.html