Java : guava Futures API with ListenableFuture

Question

我正在尝试通过简单的示例更好地理解 guava API:首先，我实例化返回“hello”的 ListenableFuture然后我使用 Futures.transform() 将我的“hello”转换为“HELLO”但我没有得到任何结果。

这是我的代码(我删除了 ListenableFuture 实现中的其他方法以使事情变得更容易):

public static void main(String[] args) throws InterruptedException, ExecutionException {
        ListenableFuture<String> future = getString();
        ListenableFuture<String> future2 = Futures.transform(future, new Function<String,String>() {
            @Override
            public String apply(String input) {
                return input.toUpperCase();
            }

        });
        System.out.println(future.get());  //print "hello"
        System.out.println(future2.get());  //blocking, never ends...no result
    }


    private static ListenableFuture<String> getString() {
        return new ListenableFuture<String>() {

            @Override
            public String get() throws InterruptedException, ExecutionException {
                return "hello";
            }

        };
    }

Answer 1

这可能表明您删除了“ListenableFuture 实现中的其他方法”中的错误，以使事情变得更容易。

不要实现您自己的 ListenableFuture，而是使用 Futures.immediateFuture("hello") 来获得正确的实现。