如何使用ExecutorService管理未知数量的调用项的返回值？

Question

我想创建一个具有固定线程池大小的singleton-ExecutorService。另一个线程将向ExecutorService提供调用项，我希望在执行完成后立即解析调用项的结果（最好）。

我真的不确定如何适当地执行这一点。我最初的想法是singleton-ES中的一个方法，它通过“submit（Callable）”向ExecutorService添加一个Callable，并将得到的Future存储在Singleton中的HashMap或ArrayList中。另一个线程将在给定的时间间隔内检查Futures的结果。

但不知何故，这个解决方案并不“感觉正确”，我在其他地方也没有找到解决方案，所以在我编写代码之前，我会问你们一些我后来后悔的东西。你会如何处理这个问题？

我期待着你的回复！

Answer 1

import java.util.concurrent.*;

public class PostProcExecutor extends ThreadPoolExecutor {

  // adjust the constructor to your desired threading policy
  public PostProcExecutor(int corePoolSize, int maximumPoolSize,
      long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
    super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
  }

  @Override
  protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
    return new FutureTask<T>(callable) {
      @Override
      protected void done()
      {
        if(!isCancelled()) try {
          processResult(get());
        } catch(InterruptedException ex) {
          throw new AssertionError("on complete task", ex);
        } catch(ExecutionException ex) {
          // no result available
        }
      }
    };
  }

  protected void processResult(Object o)
  {
    System.out.println("Result "+o);// do your post-processing here
  }
}