public static void main(String[] args) throws InterruptedException {

Long tiem = System.currentTimeMillis();

List shopsList = new ArrayList<>();

List> futures = new ArrayList();

shopsList.forEach(item -> futures.add(CompletableFuture.runAsync(() -> log.error(item))));

shopsList.forEach(item -> futures.add(CompletableFuture.completedFuture(item).thenAcceptAsync(s -> log.error(item))));

shopsList.forEach(item -> futures.add(CompletableFuture.supplyAsync(() -> item).thenAccept(s -> log.error(item))));

CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).thenRunAsync(() -> log.error("整体装修完成"));

CompletableFuture.allOf(futures.toArray(new CompletableFuture[futures.size()])).join();

long end = System.currentTimeMillis();

}