简单的CompletableFuture。SupplySync（）导致IllegalMonitorStateException错误

Question

我正在java8中尝试：

  public static void main(String[] args) throws Exception {
    CompletableFuture<Integer> future = CompletableFuture.supplyAsync(
      () -> { return 911; });
    future.whenComplete(
      (result, error) -> {
        System.out.println("Alarm:" + result);
        error.printStackTrace();
      }
    );
    future.wait();
  }

运行时，我得到以下输出：

Alarm:911
[WARNING]
java.lang.IllegalMonitorStateException
    at java.lang.Object.wait (Native Method)
    at java.lang.Object.wait (Object.java:502)
    at mygroup.UseCompletableFuture.main (UseCompletableFuture.java:15)
    at org.codehaus.mojo.exec.ExecJavaMojo$1.run (ExecJavaMojo.java:254)
    at java.lang.Thread.run (Thread.java:748)

是否需要“错误”信息？我的代码片段中有没有遗漏什么？

Answer 1

显示堆栈跟踪的异常由future引发。wait（），与第二个CompletableFuture的错误参数无关。之所以发生这种情况，是因为调用它的线程需要持有对象的监视器。有关线程成为对象监视器所有者的含义的描述，请参见本文。您的代码基本上必须在同步块中才能调用wait（）或notify（）。您可能打算调用get（），wait（）/notify（）方法是对象继承的通用同步方法，自Java诞生以来就一直存在。

至于错误参数，它实际上是空的，因为第一阶段正常完成。因此，该行出现错误。printStackTrace（）应该抛出一个NPE。然而，您的代码根本无法处理。它被抛出到执行stage的异步线程中，并保持静默。请参阅与此行为相关的帖子。

我怀疑您想在未来调用get（）方法。首先，您应该将第二阶段分配给一个变量（Future仍在引用第一阶段）：

future = future.whenComplete(
      (result, error) -> {
        System.out.println("Alarm:" + result);
        System.out.println(error);
        error.printStackTrace();
      }
);

然后可以对其调用get（），这允许您处理ExecutionException，它将包装第二阶段发生的NPE：

try {
    result = future.get();
    System.out.println(result);
} catch (InterruptedException e) {
    ...
} catch (ExecutionException e) {
    ...
}

Answer 2

etc方法派生自Object类。如果需要使用它，则需要监控对象。

在您的情况下，您不需要监视，但需要“等待可完成的未来完成”。在这种情况下，您需要从等待切换到获取方法。