CompletableFuture 使用交流（其实是困解）

[RedBeanIce]

如下代码所示，我使用 CompletableFuture 进行多线程的下载

但是我的 map 里面有 29 个图片 URL，我只得到了 26 张，所以求助大佬们，

1，我的代码哪里有问题

2，求助完整的 CompletableFuture 的使用方式

 private static void downloadCompletableFuture(Map<String, String> map) {
      try {
          List<CompletableFuture<Void>> futureList = new ArrayList<>();
          for (Map.Entry<String, String> stringStringEntry : map.entrySet()) {
              // image Url
              String imageUrl = stringStringEntry.getValue();
              CompletableFuture<Void> future = CompletableFuture.runAsync(new Runnable() {
                  @Override
                  public void run() {
                      // download picture
                      DownloadPicture3.download(imageUrl);
                  }
              });
              futureList.add(future);
          }
          CompletableFuture<Void> allDoneFuture =
          		CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0]));
          allDoneFuture.get(20, TimeUnit.SECONDS);
      } catch (Exception e) {
          e.printStackTrace();
      } finally {
          log.info("end");
          // 11:27:37.442 [main] INFO com.ice.http.JucDownloadPicture
      }
  }
  ```

[AllanAG]

既然使用了 CompletableFuture，最好使用异步的方式完成整个流程。
1 图片下载不够，推测是超时时间太短，allDoneFuture.get(20, TimeUnit.SECONDS);20s 执行时间不够
2 可以下面那段代码修改成这种方式试试
```
CompletableFuture<Void> allDoneFuture =
CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0]));
allDoneFuture.whenCompleteAsync((void1, void2) -> {
// 所有完成回调
log.info("end");
});
```

[RedBeanIce]

@AllanAG
#1 谢谢!!!!!!我现在去试试。

[RedBeanIce]

@AllanAG

#1 实际上不行，whenCompleteAsync 虽然是在获得结果完成后执行，但是实际上，一张图片也没有，log 也没有打印

```
private static void downloadCompletableFuture2(Map<String, String> map) {
try {
List<CompletableFuture<Void>> futureList = new ArrayList<>();
for (Map.Entry<String, String> stringStringEntry : map.entrySet()) {
// image Url
String imageUrl = stringStringEntry.getValue();
CompletableFuture<Void> future = CompletableFuture.runAsync(new Runnable() {
@Override
public void run() {
// download picture
log.info("下载所花时间 = " + DownloadPicture3.download(imageUrl));
}
});
futureList.add(future);
}
CompletableFuture<Void> allDoneFuture = CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0]));
allDoneFuture.whenCompleteAsync((void1, void2) -> {
// 所有完成回调
log.info("================================end");
});

} catch (Exception e) {
e.printStackTrace();
} finally {
log.info("end");
// 11:27:37.442 [main] INFO com.ice.http.JucDownloadPicture
}
}
```

[wysnylc]

收集的资料

[putaozhenhaochi]

用有返回结果的方法控制看看

[mango88]

@RedBeanIce

CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])).join();

阻塞等待所有的完成

[RedBeanIce]

@wysnylc
#4 图裂开。

[RedBeanIce]

@mango88

#6 不行，仍然少了三张

CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])).join();

[RedBeanIce]

@putaozhenhaochi
#5 求推荐，我已经人傻了。。。。。

[mango88]

@RedBeanIce

少三张，可能就不是并行的原因了，也许是下载报错了吧

[RedBeanIce]

@mango88
#6

https://imgchr.com/i/wk77B6

[RedBeanIce]

@mango88
#10

我同时使用一个普通方法下载，然后使用的 completablefuture 下载，一前一后执行，，前面的普通方法还是 29 张，但是一到后面这个就少了 2-3 张，每次执行不等。

[putaozhenhaochi]

@RedBeanIce 哈哈 CompletableFuture 不熟

要不试试 Stream 并行：
map.values().stream().parallel().forEach( v->{
System.out.println(v);
});

[cheng6563]

Java 这几个 API 实在太复杂了

[zhady009]

用这个都要加个 exceptionally(tx -> {log...})
不然你找不出问题

[mango88]

奇怪了，看起来没啥问题。DownloadPictutre 方法能简单贴一下吗 ？

[cs419]

排查手段不详细
既然下载有缺失
那把那 3 个失败的单独跑一遍代码是什么结果 （排除这 3 个链接就有问题）
再针对下载成功的 26 个链接，下载 50 次 又是啥结果 （排除任务太多）

在方法 DownloadPicture3.download(imageUrl); 前后打印序号
确保 download 方法 成功的确完成了 50 次调用
如果这里没毛病，那就是 download 方法内部执行出了问题

获取结果 allDoneFuture.get() 不使用超时时间
allDoneFuture.exceptionally(e->{
System.out.println("出错-"+ e.getMessage());
e.printStackTrace();
});
打印报错

[Narcissu5]

```java
DownloadPicture3.download(imageUrl);
```

比较可能是这个方法有线程安全的问题。另外如果 IO 不是异步的，使用异步就没意义。如果 IO 是异步的，那么这个方法本身就应该返回的是 Future，不需要在 runAsync 。另外 runAsync 本身会使用`ForkJoinPool#commonPool()`,而 ForkJoinPool 里面是不能放异步方法的，你这样子可能把整个 JVM 都拖慢

[coldear]

add more logs to debug.

[allan888]

download 之前 random 的等几秒钟试试？有可能有的网站图片会防止太多并发的连接。
大概这样：
Thread.sleep(ThreadLocalRandom.current().nextInt(0, 15000));
DownloadPicture3.download(imageUrl);