从内部类引用的 JAVA 局部变量必须是最终的或有效的最终变量

Question

我正在尝试返回stats对象。

但我得到了

从内部类引用的局部变量必须是 final，或者 有效最终

on stats = statistics; 如何返回对象，但确保.close();运行？

 public static Statistics getStatistics(String environmentName) {
    Container container = getContainer(environmentName);
    Statistics stats = new Statistics();
    try {
        dockerClient().statsCmd(container.getId()).exec(new ResultCallback<Statistics>() {
            @Override
            public void onStart(Closeable closeable) {
            }
            @Override
            public void onNext(Statistics statistics) {
                stats = statistics;
            }
            @Override
            public void onError(Throwable throwable) {
            }
            @Override
            public void onComplete() {
            }
            @Override
            public void close() throws IOException {
            }
        }).close();
    } catch (IOException e) {
        e.printStackTrace();
    }
    return stats;
}

Answer 1

您想调用getStatistics并立即使用生成的统计信息。这称为同步用法。

但实际上，人们只能通过回调异步地通知统计数据最终到达。

所以改变：

f(String env) {
    Statistics stats = getStatistics(env);
    g(stats);
}

自

f(String env) {
    retrievStatistics(env);
}
public static void retrieveStatistics(String environmentName) {
    Container container = getContainer(environmentName);
    stats = null;
    try {
        dockerClient().statsCmd(container.getId()).exec(new ResultCallback<Statistics>() {
            Statistics stats;
            @Override
            public void onNext(Statistics statistics) {
                g(statistics);
                stats = statistics; // Alternative when using onComplete instead.
            }
            @Override public void onStart(Closeable closeable) {}
            @Override public void onError(Throwable throwable) { }
            @Override public void onComplete() {
                g(stats); // Or this
            }
            @Override public void close() throws IOException { }
        }).close();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

像您一样繁忙的等待循环是次优的。

Answer 2

您可以尝试使用 java.util.concurrent.CompletableFuture (java 8(。在这种情况下：

public static Statistics getStatistics(String environmentName) {
    Container container = null;
    CompletableFuture<Statistics> future = new CompletableFuture<>();
    try {
        dockerClient().statsCmd(container.getId()).exec(new ResultCallback<Statistics>() {
            @Override
            public void onStart(Closeable closeable) {
            }
            @Override
            public void onNext(Statistics statistics) {
                if (!future.isDone()) {
                    future.complete(statistics);
                }
            }
            @Override
            public void onError(Throwable throwable) {
                future.completeExceptionally(throwable);
            }
            @Override
            public void onComplete() {
                if (!future.isDone()) {
                    future.complete(null);
                }
            }
            @Override
            public void close() throws IOException {
            }
        }).close();
    } catch (IOException e) {
        e.printStackTrace();
    }
    try {
        // wait until statistics resolved
        return future.get();
    } catch (Exception e) {
        throw new RuntimeException(e.getMessage(), e);
    }
}

或者，如果 exec 代码是同步的，则可以使用 AtomicReference，例如，作为临时容器。该方法将类似于上面的CompletableFuture示例，但开销更少

Answer 3

您正在创建一个匿名的内部类：

new ResultCallback<Statistics>() { @Override public void onStart(Closeable closeable) { } @Override public void onNext(Statistics statistics) { stats = statistics; } @Override public void onError(Throwable throwable) { } @Override public void onComplete() { } @Override public void close() throws IOException { } }).close();

问题是你在方法中定义统计信息是不必要的，因为你在匿名内部类中再次定义它@Override public void onNext(Statistics statistics) { stats = statistics; }

相反，尝试直接在类中声明变量并以 null 初始化。内部函数仅在匿名类中重新定义它。