Java中promise的概念

Question

是否有在java中使用Promise（就像在JavaScript中使用ut一样）而不是使用嵌套回调的概念？

如果是这样，是否有一个在java中实现回调和链接处理程序的示例？

Answer 1

如果你想在Java7之前做Promise，“java-Promise”可能会很有用。（当然它适用于Java8）

您可以轻松地控制异步操作，如JavaScript的Promise。

https://github.com/riversun/java-promise

示例

import org.riversun.promise.Promise;
public class Example {

    public static void main(String[] args) {
        Promise.resolve("foo")
                .then(new Promise((action, data) -> {
                    new Thread(() -> {
                        String newData = data + "bar";
                        action.resolve(newData);
                    }).start();
                }))
                .then(new Promise((action, data) -> {
                    System.out.println(data);
                    action.resolve();
                }))
                .start();
        System.out.println("Promise in Java");
    }
}

结果：

Java foobar中的Promise

Answer 2

2017年7月20日更新

我想编辑还有一个名为“ReactFX”的库，它应该是JavaFX作为一个反应式框架。据我所见，有许多反应式Java库，由于Play基于反应式主体，我假设这些反应式库遵循相同的非阻塞i/o原则，异步调用从服务器到客户端再返回，同时通信由任何一端发送。

这些库似乎是为客户端设计的，但也可能有一个服务器反应库，但我认为使用Play更明智！使用其中一个客户端反应库。

你可以看看https://www.playframework.com/

在此处实现此功能的

https://www.playframework.com/documentation/2.2.0/api/java/play/libs/F.Promise.html

附加读数https://www.playframework.com/documentation/2.5.x/JavaAsync

由于游戏的工作方式，动作代码必须尽可能快，即无阻塞。那么，如果我们还不能计算结果，我们应该从我们的行动中得到什么回报呢？我们应该回报对结果的promise！

Java 8提供了一个名为CompletionStage的通用promise API。完成阶段

在等待响应时，将阻止web客户端，但不会阻止服务器上的任何内容，并且可以使用服务器资源为其他客户端提供服务。

创建完成阶段

CompletionStage<Double> promiseOfPIValue = computePIAsynchronously();
CompletionStage<Result> promiseOfResult = promiseOfPIValue.thenApply(pi ->
                ok("PI value computed: " + pi)
);

Play asynchronous API方法为您提供了一个完成阶段（CompletionStage）。当您使用播放调用外部web服务时，就是这种情况。libs。WS-API，或者如果您使用Akka来安排异步任务，或者使用play与参与者通信。libs。阿卡

异步执行代码块并获得CompletionStage的一种简单方法是使用CompletableFuture.supplyAsync（）助手：

CompletionStage<Integer> promiseOfInt = CompletableFuture.supplyAsync(() -> intensiveComputation());

注意：了解哪些线程代码在哪些promise上运行很重要。这里，密集的计算将只在另一个线程上运行。

您无法通过将同步IO包装在完成阶段（CompletionStage）中，神奇地将其变为异步IO。如果无法更改应用程序的体系结构以避免阻塞操作，那么在某个时候必须执行该操作，并且该线程将阻塞。因此，除了将操作封装在CompletionStage中之外，还需要将其配置为在单独的执行上下文中运行，该上下文已配置了足够的线程来处理预期的并发性。有关更多信息，请参阅了解播放线程池。

使用Actors进行阻塞操作也很有帮助。Actors提供了一个干净的模型来处理超时和故障、设置阻塞执行上下文以及管理可能与服务关联的任何状态。Actors还提供了ScatterGatherFirstCompletedRout等模式来解决同时的缓存和数据库请求，并允许在后端服务器集群上远程执行。但是根据您的需要，Actor可能会被过度使用。

到目前为止，我们一直在返回结果。要发送异步结果，我们的操作需要返回一个CompletionStage

public CompletionStage<Result> index() {
    return CompletableFuture.supplyAsync(() -> intensiveComputation())
            .thenApply(i -> ok("Got result: " + i));
}

默认情况下，动作是异步的。默认情况下，播放动作是异步的。例如，在下面的控制器代码中，返回的结果内部包含在promise中：

public Result index() {
    return ok("Got request " + request() + "!");
}

注意：操作代码是返回Result还是CompletionStage

关于CompletionStage的一些信息

https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletionStage.html

这是@Debosmit Ray在回答CompletableFuture时提到的类的一个子类

这个由领英开发的YouTube视频布里克曼先生解释了一点关于promise的内容

https://youtu.be/8z3h4Uv9YbE?t=15m46s

和

https://www.youtube.com/watch?v=4b1XLka0UIw

我相信第一个视频给出了一个promise的例子，第二个视频也可能给出一些好的信息，我真的不记得哪个视频有什么内容。

不管怎样，这里的信息都很好，值得研究。

我个人不使用Play，但我已经看了很长很长时间，因为它做了很多非常好的东西。

Answer 3

是的！Java 8将其称为CompletableFuture。它可以让你实现这样的东西。

class MyCompletableFuture<T> extends CompletableFuture<T> {

   static final Executor myExecutor = ...;

   public MyCompletableFuture() { }

   public <U> CompletableFuture<U> newIncompleteFuture() {
       return new MyCompletableFuture<U>();
   }

   public Executor defaultExecutor() {
       return myExecutor; 
   }

   public void obtrudeValue(T value) {
       throw new UnsupportedOperationException();
   }
   public void obtrudeException(Throwable ex) {
       throw new UnsupportedOperationException();
   }
}

基本设计是一个半流畅的API，您可以在其中安排：

MyCompletableFuture<String> f = ...; g = ...
   f.then((s -> aStringFunction(s)).thenAsync(s -> ...);
or
   f.andThen(g, (s, t) -> combineStrings).or(CompletableFuture.async(()->...)....