java并发编程的ExecutorService如何使用？

Question

我正在使用下面的代码在远程服务器上上传图片。当我在下面使用时，它会将所有图片同时上传到远程服务器上。

List<Future<String>> futureList = new ArrayList<Future<String>>();
ExecutorService execService = Executors.newFixedThreadPool(Images.size());
for (IImage image : Images) { 
  try {
    //execService.execute(lServerRequest.new uploadImages(image.getDataPath(),image.getDisplayName()));
    singleFuture = execService.submit(lServerRequest.new uploadImages(image.getDataPath(),image.getDisplayName()));
    //Log.d("","singleFuture -------"+singleFuture.get());
    futureList.add(singleFuture);
    Log.d("","futureList Size:"+futureList.size());
  } catch(Exception e){
    execService.shutdown();
  }

每当我使用下面的代码时

   singleFuture = execService.submit(lServerRequest.new uploadImages(image.getDataPath(),image.getDisplayName()));
//Log.d("","singleFuture -------"+singleFuture.get());
    futureList.add(singleFuture);

将所有未来对象添加到futurelist，立即从runnable返回（在runnable中等待，直到所有图像上传完成（后台上传处理正在进行））

但是每当我在上面的代码中取消注释时，在成功上传每个图像后，它都会从 runnable 返回。

singleFuture = execService.submit(lServerRequest.new uploadImages(image.getDataPath(),image.getDisplayName()));
Log.d("","singleFuture -------"+singleFuture.get());
futureList.add(singleFuture);

我的代码有什么问题吗？是否可以一次连接更多远程服务器或服务器上有任何负载？如何使用并行编程java上传图像？请指导？

submit() 和 execute() 函数效果一样吗？

Answer 1

当您致电singleFuture.get() 时，您正在等待操作完成。所以循环不会继续执行下一条语句，直到这条语句返回结果。

您需要在第一个循环中提交您的任务，然后，另一个循环应遍历列表中的结果 future.get() 以使其异步

来自@andersoj 的回答；

池大小应该与您的 CPU 内核有关。不是您手头的图像数量。假设您有 2 个核心 CPU，则图像上传 io 时间的系数为 5（只是我猜测的系数）。

POOL_SIZE = NUM​​_OF_CPU_CORE*系数；

Answer 2

submit() 将任务添加到队列并返回Future。 execute() 不返回 Future。另见here。您观察到的不同排序可能是 submit() 内部发生的额外管理的副作用，并且可能无关紧要。 （但请参阅@fmucar 的回答...）

不确定您的问题是什么...

根据您要上传的图像数量来调整线程池的大小实际上没有意义——可能少量线程就足够了，因为您只是试图保持一些 TCP 流的馈送。每张图片一个线程，如果图片列表很大，不会给你买任何东西。

如果您收集Futures 只是为了知道上传何时完成，请考虑以下方法之一：

• 使用invokeAll()，它只会阻塞直到所有提交的任务完成（请参阅my answer here for more details）
• 使用CompletionService

编辑添加：很好，@fmucar，在记录器行中对.get() 的调用强制顺序，因此线程池是一种浪费。

invokeAll() 示例

这里试图给你一个invokeAll() 的例子；不确定它是否与您的代码完全匹配。

final int poolSize = ...;  // see fmucar's answer
final ExecutorService execService = Executors.newFixedThreadPool(poolSize);
final List<Callable<>> uploadTasks = new ArrayList<Callable<>>();

for (final IImage image : Images) { 
   // maybe I got this wrong?  Can't quite parse your code.
   Callable<String> uTask = new uploadImages(image.getDataPath(),image.getDisplayName());
   uploadTasks.add(uTask);
}
// this thread will block here until all the tasks complete
final List<Future<String>> futureList = execService.invokeAll();
// or you can toss the result entirely if the futures don't matter.