Java未来：如何在执行Aysnc调用时解除主线程阻塞

Question

当我使用ExecutorService进行异步调用时，它会返回Future对象。根据它返回的布尔值，我必须记录异步调用的状态。

但当我试图从future对象调用get方法时，它会阻止主线程的执行。

是否可以解除屏蔽主线程执行？

public class FutureExample {

    static HystrixCommand<Boolean> hystrixCommand;

    public FutureExample(HystrixCommand<Boolean> hystrixCommand){
        FutureExample.hystrixCommand = hystrixCommand;
    }

    public static void main(String[] args) throws InterruptedException, ExecutionException {


        Boolean something = asyncCall();

        if(something) {
            System.out.println("Future task is done");
        }

        System.out.println("Don't wait for async call");

    }

    private static Boolean asyncCall() throws InterruptedException, ExecutionException {

        Future<Boolean> response = hystrixCommand.queue(); // Aysnc Call to remote server

        return response.get(); //this is blocking main thread
    }

}

Answer 1

如果需要在异步任务运行时在主线程中执行代码，则需要重新设计asyncCall方法，使其返回未来。

举个例子：

private static Future<Boolean> asyncCall() 
      throws InterruptedException, ExecutionException {

    return hystrixCommand.queue(); 
}

通过这种方式，main方法就何时阻塞/等待进行调用：

public static void main(String[] args) 
     throws InterruptedException, ExecutionException {

    Future<Boolean> something = asyncCall();

    //do something while async call is running

    //to check whether it's done running:
    if(something.isDone()) {
        System.out.println("Future task is done");
    }

    //when you're finally ready to wait:
    System.out.println("Waiting for async call to finish");
    Boolean result = something.get();
}

Answer 2

根据JavaDocs的说法，get（）方法在必要时等待计算完成，然后检索其结果。

如果希望在任务完成后获得结果，请使用isDone（）函数，如果任务完成（正常、异常等），该函数将返回true。然后调用get（）。

此外，您还可以使用get（长超时，时间单位）函数仅等待给定的时间段。在这种情况下，如果超时或任务已完成，主线程将自动“解锁”。

Answer 3

未来的好处是能够在答案到来之前释放线程。所以我建议您使用未来的实现，比如CompletableFuture：

final ExecutorService executorService = Executors.newFixedThreadPool(10);

CompletableFuture.supplyAsync(() -> {
    try {
        return hystrixCommand.queue();
    } catch (Exception e) {
        return false;
    }
}, executorService);

这将在另一个线程上工作，当未来结束时，它将被完成。