如何从可调用接口返回未来对象（executorService.submit 的内部工作）答案

【问题标题】：How to return future object from callable interface (internal working of executorService.submit)如何从可调用接口返回未来对象（executorService.submit 的内部工作）
【发布时间】：2017-02-24 11:51:35
【问题描述】：

我试图了解在运行 executorService.submit(Callable); 时如何创建未来对象

例如，假设我创建了一个线程池，我在其中传递了可调用的实现

class FactorialCalculator implements Callable<Long> { 
  private int number; 
  public FactorialCalculator(int number) { 
    this.number = number; 
  } 
  @Override 
  public Long call() throws Exception { 
        return (number*number); 
  }
}

我想返回未来对象，这样我就可以从调用函数中获取返回值。我的自定义线程池看起来像this

class MyThreadPool implements java.util.concurrent.Executor 
{
    private final java.util.concurrent.BlockingQueue<Callable> queue;

    public MyThreadPool(int numThreads) {
        queue = new java.util.concurrent.LinkedBlockingQueue<>();
        for (int i=0 ; i<numThreads ; i++) {
            new Thread(new Runnable(){
                @Override
                public void run() {
                    while(true) {
                        queue.take().call();
                    }
                }
            }).start();
        }
    }

    @Override
    public void submit(Callable command) {
        queue.put(command);
    }
}

如果我这样做了

MyThreadPool mypool = new MyThreadPool(10);
mypool.submit(new FactorialCalculator(10));

我想提交返回future的方法，这样我就可以检查线程是否已完成执行的返回值。如何返回未来对象。

【问题讨论】：

标签： java multithreading threadpool executorservice java.util.concurrent

【解决方案1】：

最简单的方法是将您的可调用对象包装在 FutureTask 中：

@Override
public <T> Future<T> submit(Callable<T> callable) {
    FutureTask<T> future = new FutureTask(callable);
    queue.put(future);
    return future;
}

当然，更简单的解决方案是使用Executors.newFixedThreadPool，而不是自己重新实现它。

【讨论】：