java - 如何在java中创建一个完整的未来

Question

在 Java 中构建完整的未来的最佳方式是什么？我在下面实现了我自己的CompletedFuture，但希望这样的东西已经存在。

public class CompletedFuture<T> implements Future<T> {
    private final T result;

    public CompletedFuture(final T result) {
        this.result = result;
    }

    @Override
    public boolean cancel(final boolean b) {
        return false;
    }

    @Override
    public boolean isCancelled() {
        return false;
    }

    @Override
    public boolean isDone() {
        return true;
    }

    @Override
    public T get() throws InterruptedException, ExecutionException {
        return this.result;
    }

    @Override
    public T get(final long l, final TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {
        return get();
    }
}

Answer 1

在 Java 8 中，您可以使用内置的 CompletableFuture：

 Future future = CompletableFuture.completedFuture(value);

Answer 2

Apache Commons Lang 定义了类似的实现，称为 ConstantFuture，您可以通过调用来获取它：

Future<T> future = ConcurrentUtils.constantFuture(T myValue);

Answer 3

Guava定义了Futures.immediateFuture(value)，它完成了这项工作。

Answer 4

FutureTask<String> ft = new FutureTask<>(() -> "foo");
ft.run();

System.out.println(ft.get());

将打印出“foo”；

您还可以有一个 Future 在调用 get() 时引发异常：

FutureTask<String> ft = new FutureTask<>(() -> {throw new RuntimeException("exception!");});
ft.run();

Answer 5

我在 Java rt.jar 中找到了一个与您的非常相似的类

com.sun.xml.internal.ws.util.CompletedFuture

它还允许您指定在调用 get() 时可以抛出的异常。如果您不想引发异常，只需将其设置为 null 即可。

Answer 6

在 Java 6 中，您可以使用以下内容：

Promise<T> p = new Promise<T>();
p.resolve(value);
return p.getFuture();