问题描述
我正在尝试将特定时间的最大打开httpconnection设置为10。如果第11个请求到来,它应该等待httpconnection之一空闲。我的代码如下。我不确定如何测试它是否按预期工作。有人可以验证一下吗?
private final ExecutorService executorService = Executors.newFixedThreadPool(10);
private final HttpClient httpClient = HttpClient.newBuilder()
.executor(executorService)
.build();
//BElow code is inside my method
List<CompletableFuture<String>> result = targets.stream()
.map("myjson"-> httpClient.sendAsync(
HttpRequest.newBuilder()
.POST(HttpRequest.BodyPublishers.ofString("myjson"))
.uri(URI.create("myURl"))
.setHeader("Authorization","Basic =")
.build(),HttpResponse.BodyHandlers.ofString())
.thenApply(response -> response.body()))
.collect(Collectors.toList());
for (CompletableFuture<String> future : result) {
System.out.println(future.get());
}
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)