vavr 的 Future 不执行某些代码，使用方法 andThen

Question

在这段代码中，我有两种使用 vavr 库的方法。从这个库中，我使用 Future 和方法，然后，这个方法在未来完成时运行，这是同步的，但是当线程调用这个方法中的方法“printTime”时，所有程序都停止了，测试是成功。 这是方法

    public void printTime(String m){
    String pattern = "HH:mm:ss:SSS";
    SimpleDateFormat formato = new SimpleDateFormat(pattern);
    Date date = new Date();
    String dateString = formato.format(date);
    String retorno = dateString+" "+m;
    System.out.println(retorno);
}

这就是测试

    @Test
public void futuroAndThen() {
    Future<String> f1 = Future.of(()->"Julian");
    Future<String> f2 = Future.of(()->"Carvajal");
    Future<String> f3 = Future.of(()->"Montoya");

    Future<String> fResult = f3.andThen(x-> {
        System.out.println(x.get());
        System.out.println(Thread.currentThread().getName());
        printTime("andThen2"+Thread.currentThread().getName());
    }).andThen(y->{
        System.out.println("y:"+y.get());
        System.out.println(Thread.currentThread().getName());
        f2.andThen(x->{
            System.out.println("f2: "+x.get());
            System.out.println("thread f2 "+Thread.currentThread().getName());
        });
        printTime("andThen2"+Thread.currentThread().getName());
    });

}

最后在 printTime 方法中的结果是：

Montoya
pool-1-thread-3
y:Montoya
pool-1-thread-1
f2: Carvajal
thread f2 pool-1-thread-3

和用的方法是：

Montoya
pool-1-thread-1

但有时控制台是空的。

非常感谢:)

Answer 1

您的测试完成，主 JUnit 运行线程在 Future 完成之前退出 JVM。这就是您在控制台上得到不一致结果的原因，这完全取决于 Futures 的执行时间，从 vavr 0.9.2 开始，这发生在 cached thread pool 中。

如果要同步等待Future完成，可以使用

fResult = fResult.await();

在测试结束时。然后您的测试将等待 Future 实例完成，您的输出将是：

Montoya
pool-1-thread-4
23:56:59:570 andThen2pool-1-thread-4
y:Montoya
pool-1-thread-3
f2: Carvajal
thread f2 pool-1-thread-4
23:56:59:572 andThen2pool-1-thread-3