1

在这段代码中，我有两种使用 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

但有时控制台是空的。

非常感谢您 ：）

4

1 回答 1

0

您的测试完成并且主运行器线程在可能完成JUnit之前退出 JVM 。Future这就是为什么您在控制台上得到不一致的结果，这完全取决于Futures 的执行时间，从 vavr 0.9.2 开始，这发生在缓存的线程池中。

如果要同步等待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
于 2018-06-28T22:22:37.167 回答