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

Question

我正在尝试返回统计信息对象。

但我得到了

从内部类引用的局部变量必须是最终变量或实际上是最终变量

on < code > stats = statistics如何返回对象，但要确保< code >。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

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

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公共 void onNext（Statistics statistics） { stats = statistics; }

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

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

您想调用＜code＞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();
    }
}

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