java - 为什么我的 threadExecutor 调用同一个回调两次？

Question

我有这个代码:

public <T> T executeCodeBlockWithTimeLimit(String criticalBlockTimeOutMilli, Callable<T> callable) throws
        Exception {
    ExecutorService service = Executors.newSingleThreadExecutor();
    Future<T> future = service.submit(callable);

    startStopWatch();
    T result;

    if (criticalBlockTimeOutMilli != null) {
        result = future.get(Long.parseLong(criticalBlockTimeOutMilli), TimeUnit.MILLISECONDS);
    } else {
        result = callable.call();
    }
    long timeElapsed = stopStopWatch();
    e2eResult.runTime = timeElapsed;
    service.shutdown();
    return result;
}

在外部方法中:

    Callable<Void> callable = new
            Callable<Void>() {
                @Override
                public Void call() throws
                        Exception {

                    System.out.println("22222");

                    return null;
                }
            };
    timerUtils.executeCodeBlockWithTimeLimit(criticalBlockTimeOutMilli, callable);

我看到了控制台打印

22222
22222

为什么要调用两次？

Answer 1

当您从 Executor 获得 Future 时 submit方法 这个调用 Callable 对象方法并存储结果。在您的代码中，您首先获得 Future 然后如果变量 criticalBlockTimeOutMilli是<b>null</b>你调用call() Callable 对象上的方法。这意味着执行两次 Callable 对象。

您应该使用 get()方法，因为这个方法使用已经从您的 Future 对象收集的结果(参见 Future#get() method )。