Future 实现方式

---

import java.io.IOException;  
import java.net.URL;  
import java.util.ArrayList;  
import java.util.List;  
import java.util.concurrent.Callable;  
import java.util.concurrent.ExecutionException;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
import java.util.concurrent.Future;  public class ImageDownloader {  public static void main(String[] args) {  // 假设这是你的图片URL列表  List<String> imageUrls = List.of(  "http://example.com/image1.jpg",  "http://example.com/image2.jpg",  // ... 其他图片URL  );  ExecutorService executorService = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池  List<Future<Void>> futures = new ArrayList<>();  for (String imageUrl : imageUrls) {  Future<Void> future = executorService.submit(new DownloadTask(imageUrl));  futures.add(future);  }  // 等待所有任务完成  for (Future<Void> future : futures) {  try {  future.get(); // 这会阻塞，直到任务完成或抛出异常  } catch (InterruptedException | ExecutionException e) {  e.printStackTrace();  }  }  // 关闭线程池  executorService.shutdown();  System.out.println("所有图片已下载完成");  }  static class DownloadTask implements Callable<Void> {  private final String imageUrl;  public DownloadTask(String imageUrl) {  this.imageUrl = imageUrl;  }  @Override  public Void call() throws Exception {  // 这里是下载图片的代码，你可以使用任何你喜欢的库或方法来实现  URL url = new URL(imageUrl);  // ... 下载图片并保存到本地或其他地方  return null;  }  }  
}

CountDownLatch 实现方式

---

import java.io.IOException;  
import java.net.URL;  
import java.util.concurrent.CountDownLatch;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  public class ImageDownloaderWithCountDownLatch {  public static void main(String[] args) {  // 假设这是你的图片URL列表  String[] imageUrls = {  "http://example.com/image1.jpg",  "http://example.com/image2.jpg",  // ... 其他图片URL  };  int threadCount = imageUrls.length; // 图片数量，即需要启动的线程数  CountDownLatch latch = new CountDownLatch(threadCount); // 初始化 CountDownLatch  ExecutorService executorService = Executors.newFixedThreadPool(threadCount); // 创建一个固定大小的线程池  // 提交下载任务到线程池  for (String imageUrl : imageUrls) {  executorService.submit(() -> {  try {  downloadImage(imageUrl); // 下载图片的方法  } catch (IOException e) {  e.printStackTrace();  } finally {  latch.countDown(); // 下载完成后，计数器减一  }  });  }  try {  // 等待所有图片下载完成  latch.await();  System.out.println("所有图片已下载完成");  } catch (InterruptedException e) {  e.printStackTrace();  } finally {  // 关闭线程池  executorService.shutdown();  }  }  private static void downloadImage(String imageUrl) throws IOException {  // 这里是下载图片的代码，你可以使用任何你喜欢的库或方法来实现  URL url = new URL(imageUrl);  // ... 下载图片并保存到本地或其他地方  System.out.println("下载了图片: " + imageUrl);  }  
}