Java：使用异步编程优化应用程序

Java：使用异步编程优化应用程序

受到Davide的（伟大）答案的启发，这是一个示例，一种使用简单反应（我写的我的库）并行化此方法的简便方法。请注意，使用客户端来驱动服务器上的并发性稍有不同。

例

LazyReact streamBuilder = new LazyReact(15,15);streamBuilder.fromIterable(urlRequests)      .filter(urlReq->!validateRequests.isWhitelisted(urlReq))      .forEach(request -> {ContentDetectionClient.detectContent(request);       });

说明

看起来您可以从客户端驱动并发。这意味着您可以在服务器端的线程之间分配工作，而无需执行其他工作。在此示例中，我们发出了15个并发请求，但您可以将其设置为接近服务器可以处理的最大值。您的应用程序是IO绑定，因此您可以使用很多线程来提高性能。

简单反应可作为期货之源。因此，在这里我们为对ContentDetection客户端的每次调用创建一个异步任务。我们有15个可用线程，因此可以一次对服务器进行15次调用。

Java 7

Java的JDK
8功能有一个反向移植，称为StreamSupport，您也可以通过RetroLambda反向移植Lambda表达式。

为了用CompletableFutures实现相同的解决方案，我们可以为每个合格的URL创建一个Future Task。 更新
我认为我们不需要批处理它们，我们可以使用执行器来限制活跃期货的数量。我们只需要在最后加入所有这些。

   Executor exec = Executors.newFixedThreadPool(maxActive);//15 threads   List<CompletableFuture<Void>> futures= new ArrayList<>();   for (UrlRequest request : urlRequests) { if (!validateRequests.isWhitelisted(request)) {     futures.add(CompletableFuture.runAsync(()->ContentDetectionClient.detectContent(request), exec)); }        } CompletableFuture.allOf(futures.toArray()).join();