这是使用java.util.concurrent.FutureTask的好方法吗？

Question

首先，我必须说我对API java.util.concurrent很陌生，所以也许我正在做的事情是完全错误的。

我想怎么办？

我有一个Java应用程序，它基本上运行2个单独的处理（称为 myFirstProcess ， mySecondProcess
），但是这些处理必须同时运行。

因此，我尝试这样做：

public void startMyApplication() {
    ExecutorService executor = Executors.newFixedThreadPool(2);
    FutureTask<Object> futureOne = new FutureTask<Object>(myFirstProcess);
    FutureTask<Object> futureTwo = new FutureTask<Object>(mySecondProcess);
    executor.execute(futureOne);
    executor.execute(futureTwo);
    while (!(futureOne.isDone() && futureTwo.isDone())) {
        try {
            // I wait until both processes are finished.
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    logger.info("Processing finished");
    executor.shutdown();
    // Do some processing on results
    ...
}

myFirstProcess 和 mySecondProcess
是实现的类，Callable<Object>它们的所有处理都在call（）方法中进行。

它工作得很好，但是我不确定这是正确的方法。是做我想要的好方法吗？如果没有，您能给我一些提示来增强我的代码（并使其尽可能保持简单）。

Answer 1

使用该get()方法会更好。

futureOne.get();
futureTwo.get();

两者都等待线程完成处理的通知，这为您节省了您正在使用的忙碌等待计时器，这既效率低下又不雅致。

另外，您还可以使用API get(long timeout, TimeUnit unit)来定义线程休眠和等待响应的最大时间，否则它将继续运行。

有关更多信息，请参见Java
API
。